2022-10-28 17:15:33 -07:00
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
package spyv1
import (
context "context"
grpc "google.golang.org/grpc"
codes "google.golang.org/grpc/codes"
status "google.golang.org/grpc/status"
)
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc . SupportPackageIsVersion7
// SpyRPCServiceClient is the client API for SpyRPCService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
type SpyRPCServiceClient interface {
// SubscribeSignedVAA returns a stream of signed VAA messages received on the network.
SubscribeSignedVAA ( ctx context . Context , in * SubscribeSignedVAARequest , opts ... grpc . CallOption ) ( SpyRPCService_SubscribeSignedVAAClient , error )
2022-11-09 08:39:57 -08:00
// SubscribeSignedBatchVAA returns a stream of signed VAA messages, by type, received on the network.
SubscribeSignedVAAByType ( ctx context . Context , in * SubscribeSignedVAAByTypeRequest , opts ... grpc . CallOption ) ( SpyRPCService_SubscribeSignedVAAByTypeClient , error )
2022-10-28 17:15:33 -07:00
}
type spyRPCServiceClient struct {
cc grpc . ClientConnInterface
}
func NewSpyRPCServiceClient ( cc grpc . ClientConnInterface ) SpyRPCServiceClient {
return & spyRPCServiceClient { cc }
}
func ( c * spyRPCServiceClient ) SubscribeSignedVAA ( ctx context . Context , in * SubscribeSignedVAARequest , opts ... grpc . CallOption ) ( SpyRPCService_SubscribeSignedVAAClient , error ) {
stream , err := c . cc . NewStream ( ctx , & SpyRPCService_ServiceDesc . Streams [ 0 ] , "/spy.v1.SpyRPCService/SubscribeSignedVAA" , opts ... )
if err != nil {
return nil , err
}
x := & spyRPCServiceSubscribeSignedVAAClient { stream }
if err := x . ClientStream . SendMsg ( in ) ; err != nil {
return nil , err
}
if err := x . ClientStream . CloseSend ( ) ; err != nil {
return nil , err
}
return x , nil
}
type SpyRPCService_SubscribeSignedVAAClient interface {
Recv ( ) ( * SubscribeSignedVAAResponse , error )
grpc . ClientStream
}
type spyRPCServiceSubscribeSignedVAAClient struct {
grpc . ClientStream
}
func ( x * spyRPCServiceSubscribeSignedVAAClient ) Recv ( ) ( * SubscribeSignedVAAResponse , error ) {
m := new ( SubscribeSignedVAAResponse )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
2022-11-09 08:39:57 -08:00
func ( c * spyRPCServiceClient ) SubscribeSignedVAAByType ( ctx context . Context , in * SubscribeSignedVAAByTypeRequest , opts ... grpc . CallOption ) ( SpyRPCService_SubscribeSignedVAAByTypeClient , error ) {
stream , err := c . cc . NewStream ( ctx , & SpyRPCService_ServiceDesc . Streams [ 1 ] , "/spy.v1.SpyRPCService/SubscribeSignedVAAByType" , opts ... )
if err != nil {
return nil , err
}
x := & spyRPCServiceSubscribeSignedVAAByTypeClient { stream }
if err := x . ClientStream . SendMsg ( in ) ; err != nil {
return nil , err
}
if err := x . ClientStream . CloseSend ( ) ; err != nil {
return nil , err
}
return x , nil
}
type SpyRPCService_SubscribeSignedVAAByTypeClient interface {
Recv ( ) ( * SubscribeSignedVAAByTypeResponse , error )
grpc . ClientStream
}
type spyRPCServiceSubscribeSignedVAAByTypeClient struct {
grpc . ClientStream
}
func ( x * spyRPCServiceSubscribeSignedVAAByTypeClient ) Recv ( ) ( * SubscribeSignedVAAByTypeResponse , error ) {
m := new ( SubscribeSignedVAAByTypeResponse )
if err := x . ClientStream . RecvMsg ( m ) ; err != nil {
return nil , err
}
return m , nil
}
2022-10-28 17:15:33 -07:00
// SpyRPCServiceServer is the server API for SpyRPCService service.
// All implementations must embed UnimplementedSpyRPCServiceServer
// for forward compatibility
type SpyRPCServiceServer interface {
// SubscribeSignedVAA returns a stream of signed VAA messages received on the network.
SubscribeSignedVAA ( * SubscribeSignedVAARequest , SpyRPCService_SubscribeSignedVAAServer ) error
2022-11-09 08:39:57 -08:00
// SubscribeSignedBatchVAA returns a stream of signed VAA messages, by type, received on the network.
SubscribeSignedVAAByType ( * SubscribeSignedVAAByTypeRequest , SpyRPCService_SubscribeSignedVAAByTypeServer ) error
2022-10-28 17:15:33 -07:00
mustEmbedUnimplementedSpyRPCServiceServer ( )
}
// UnimplementedSpyRPCServiceServer must be embedded to have forward compatible implementations.
type UnimplementedSpyRPCServiceServer struct {
}
func ( UnimplementedSpyRPCServiceServer ) SubscribeSignedVAA ( * SubscribeSignedVAARequest , SpyRPCService_SubscribeSignedVAAServer ) error {
return status . Errorf ( codes . Unimplemented , "method SubscribeSignedVAA not implemented" )
}
2022-11-09 08:39:57 -08:00
func ( UnimplementedSpyRPCServiceServer ) SubscribeSignedVAAByType ( * SubscribeSignedVAAByTypeRequest , SpyRPCService_SubscribeSignedVAAByTypeServer ) error {
return status . Errorf ( codes . Unimplemented , "method SubscribeSignedVAAByType not implemented" )
}
2022-10-28 17:15:33 -07:00
func ( UnimplementedSpyRPCServiceServer ) mustEmbedUnimplementedSpyRPCServiceServer ( ) { }
// UnsafeSpyRPCServiceServer may be embedded to opt out of forward compatibility for this service.
// Use of this interface is not recommended, as added methods to SpyRPCServiceServer will
// result in compilation errors.
type UnsafeSpyRPCServiceServer interface {
mustEmbedUnimplementedSpyRPCServiceServer ( )
}
func RegisterSpyRPCServiceServer ( s grpc . ServiceRegistrar , srv SpyRPCServiceServer ) {
s . RegisterService ( & SpyRPCService_ServiceDesc , srv )
}
func _SpyRPCService_SubscribeSignedVAA_Handler ( srv interface { } , stream grpc . ServerStream ) error {
m := new ( SubscribeSignedVAARequest )
if err := stream . RecvMsg ( m ) ; err != nil {
return err
}
return srv . ( SpyRPCServiceServer ) . SubscribeSignedVAA ( m , & spyRPCServiceSubscribeSignedVAAServer { stream } )
}
type SpyRPCService_SubscribeSignedVAAServer interface {
Send ( * SubscribeSignedVAAResponse ) error
grpc . ServerStream
}
type spyRPCServiceSubscribeSignedVAAServer struct {
grpc . ServerStream
}
func ( x * spyRPCServiceSubscribeSignedVAAServer ) Send ( m * SubscribeSignedVAAResponse ) error {
return x . ServerStream . SendMsg ( m )
}
2022-11-09 08:39:57 -08:00
func _SpyRPCService_SubscribeSignedVAAByType_Handler ( srv interface { } , stream grpc . ServerStream ) error {
m := new ( SubscribeSignedVAAByTypeRequest )
if err := stream . RecvMsg ( m ) ; err != nil {
return err
}
return srv . ( SpyRPCServiceServer ) . SubscribeSignedVAAByType ( m , & spyRPCServiceSubscribeSignedVAAByTypeServer { stream } )
}
type SpyRPCService_SubscribeSignedVAAByTypeServer interface {
Send ( * SubscribeSignedVAAByTypeResponse ) error
grpc . ServerStream
}
type spyRPCServiceSubscribeSignedVAAByTypeServer struct {
grpc . ServerStream
}
func ( x * spyRPCServiceSubscribeSignedVAAByTypeServer ) Send ( m * SubscribeSignedVAAByTypeResponse ) error {
return x . ServerStream . SendMsg ( m )
}
2022-10-28 17:15:33 -07:00
// SpyRPCService_ServiceDesc is the grpc.ServiceDesc for SpyRPCService service.
// It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy)
var SpyRPCService_ServiceDesc = grpc . ServiceDesc {
ServiceName : "spy.v1.SpyRPCService" ,
HandlerType : ( * SpyRPCServiceServer ) ( nil ) ,
Methods : [ ] grpc . MethodDesc { } ,
Streams : [ ] grpc . StreamDesc {
{
StreamName : "SubscribeSignedVAA" ,
Handler : _SpyRPCService_SubscribeSignedVAA_Handler ,
ServerStreams : true ,
} ,
2022-11-09 08:39:57 -08:00
{
StreamName : "SubscribeSignedVAAByType" ,
Handler : _SpyRPCService_SubscribeSignedVAAByType_Handler ,
ServerStreams : true ,
} ,
2022-10-28 17:15:33 -07:00
} ,
Metadata : "spy/v1/spy.proto" ,
}