test

package
v0.0.0-...-be5bbd5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 29, 2019 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Code generated by github.com/citradigital/protonats. DO NOT EDIT. package: cdl.protonats source: nats_test.proto

Code generated by github.com/citradigital/protonats. DO NOT EDIT. package: cdl.protonats source: nats_test.proto

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthNatsTest = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNatsTest   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterTestServiceServer 

func RegisterTestServiceServer(s *grpc.Server, srv TestServiceServer)

Types

type FeedDataRequest 

type FeedDataRequest struct {
	Data int64 `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*FeedDataRequest) Descriptor 

func (*FeedDataRequest) Descriptor() ([]byte, []int)

func (*FeedDataRequest) GetData 

func (m *FeedDataRequest) GetData() int64

func (*FeedDataRequest) Marshal 

func (m *FeedDataRequest) Marshal() (dAtA []byte, err error)

func (*FeedDataRequest) MarshalTo 

func (m *FeedDataRequest) MarshalTo(dAtA []byte) (int, error)

func (*FeedDataRequest) MarshalToSizedBuffer 

func (m *FeedDataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FeedDataRequest) ProtoMessage 

func (*FeedDataRequest) ProtoMessage()

func (*FeedDataRequest) Reset 

func (m *FeedDataRequest) Reset()

func (*FeedDataRequest) Size 

func (m *FeedDataRequest) Size() (n int)

func (*FeedDataRequest) String 

func (m *FeedDataRequest) String() string

func (*FeedDataRequest) Unmarshal 

func (m *FeedDataRequest) Unmarshal(dAtA []byte) error

func (*FeedDataRequest) XXX_DiscardUnknown 

func (m *FeedDataRequest) XXX_DiscardUnknown()

func (*FeedDataRequest) XXX_Marshal 

func (m *FeedDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeedDataRequest) XXX_Merge 

func (m *FeedDataRequest) XXX_Merge(src proto.Message)

func (*FeedDataRequest) XXX_Size 

func (m *FeedDataRequest) XXX_Size() int

func (*FeedDataRequest) XXX_Unmarshal 

func (m *FeedDataRequest) XXX_Unmarshal(b []byte) error

type FeedDataResponse 

type FeedDataResponse struct {
	Sum int64 `protobuf:"varint,1,opt,name=sum,proto3" json:"sum,omitempty"`
}

func (*FeedDataResponse) Descriptor 

func (*FeedDataResponse) Descriptor() ([]byte, []int)

func (*FeedDataResponse) GetSum 

func (m *FeedDataResponse) GetSum() int64

func (*FeedDataResponse) Marshal 

func (m *FeedDataResponse) Marshal() (dAtA []byte, err error)

func (*FeedDataResponse) MarshalTo 

func (m *FeedDataResponse) MarshalTo(dAtA []byte) (int, error)

func (*FeedDataResponse) MarshalToSizedBuffer 

func (m *FeedDataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FeedDataResponse) ProtoMessage 

func (*FeedDataResponse) ProtoMessage()

func (*FeedDataResponse) Reset 

func (m *FeedDataResponse) Reset()

func (*FeedDataResponse) Size 

func (m *FeedDataResponse) Size() (n int)

func (*FeedDataResponse) String 

func (m *FeedDataResponse) String() string

func (*FeedDataResponse) Unmarshal 

func (m *FeedDataResponse) Unmarshal(dAtA []byte) error

func (*FeedDataResponse) XXX_DiscardUnknown 

func (m *FeedDataResponse) XXX_DiscardUnknown()

func (*FeedDataResponse) XXX_Marshal 

func (m *FeedDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FeedDataResponse) XXX_Merge 

func (m *FeedDataResponse) XXX_Merge(src proto.Message)

func (*FeedDataResponse) XXX_Size 

func (m *FeedDataResponse) XXX_Size() int

func (*FeedDataResponse) XXX_Unmarshal 

func (m *FeedDataResponse) XXX_Unmarshal(b []byte) error

type Fixtures 

type Fixtures interface {
	SetTime(t time.Time)
	GetTime() time.Time
	SetValue(s string)
	GetValue() string
	SetCounter(s string)
	GetCounter(s string) int
	SetData(data int64)
	GetData() int64
}

Interface for injecting testing fixtures

type StreamDataRequest 

type StreamDataRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*StreamDataRequest) Descriptor 

func (*StreamDataRequest) Descriptor() ([]byte, []int)

func (*StreamDataRequest) GetId 

func (m *StreamDataRequest) GetId() int64

func (*StreamDataRequest) Marshal 

func (m *StreamDataRequest) Marshal() (dAtA []byte, err error)

func (*StreamDataRequest) MarshalTo 

func (m *StreamDataRequest) MarshalTo(dAtA []byte) (int, error)

func (*StreamDataRequest) MarshalToSizedBuffer 

func (m *StreamDataRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamDataRequest) ProtoMessage 

func (*StreamDataRequest) ProtoMessage()

func (*StreamDataRequest) Reset 

func (m *StreamDataRequest) Reset()

func (*StreamDataRequest) Size 

func (m *StreamDataRequest) Size() (n int)

func (*StreamDataRequest) String 

func (m *StreamDataRequest) String() string

func (*StreamDataRequest) Unmarshal 

func (m *StreamDataRequest) Unmarshal(dAtA []byte) error

func (*StreamDataRequest) XXX_DiscardUnknown 

func (m *StreamDataRequest) XXX_DiscardUnknown()

func (*StreamDataRequest) XXX_Marshal 

func (m *StreamDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamDataRequest) XXX_Merge 

func (m *StreamDataRequest) XXX_Merge(src proto.Message)

func (*StreamDataRequest) XXX_Size 

func (m *StreamDataRequest) XXX_Size() int

func (*StreamDataRequest) XXX_Unmarshal 

func (m *StreamDataRequest) XXX_Unmarshal(b []byte) error

type StreamDataResponse 

type StreamDataResponse struct {
	Data int64 `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*StreamDataResponse) Descriptor 

func (*StreamDataResponse) Descriptor() ([]byte, []int)

func (*StreamDataResponse) GetData 

func (m *StreamDataResponse) GetData() int64

func (*StreamDataResponse) Marshal 

func (m *StreamDataResponse) Marshal() (dAtA []byte, err error)

func (*StreamDataResponse) MarshalTo 

func (m *StreamDataResponse) MarshalTo(dAtA []byte) (int, error)

func (*StreamDataResponse) MarshalToSizedBuffer 

func (m *StreamDataResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamDataResponse) ProtoMessage 

func (*StreamDataResponse) ProtoMessage()

func (*StreamDataResponse) Reset 

func (m *StreamDataResponse) Reset()

func (*StreamDataResponse) Size 

func (m *StreamDataResponse) Size() (n int)

func (*StreamDataResponse) String 

func (m *StreamDataResponse) String() string

func (*StreamDataResponse) Unmarshal 

func (m *StreamDataResponse) Unmarshal(dAtA []byte) error

func (*StreamDataResponse) XXX_DiscardUnknown 

func (m *StreamDataResponse) XXX_DiscardUnknown()

func (*StreamDataResponse) XXX_Marshal 

func (m *StreamDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StreamDataResponse) XXX_Merge 

func (m *StreamDataResponse) XXX_Merge(src proto.Message)

func (*StreamDataResponse) XXX_Size 

func (m *StreamDataResponse) XXX_Size() int

func (*StreamDataResponse) XXX_Unmarshal 

func (m *StreamDataResponse) XXX_Unmarshal(b []byte) error

type TestARequest 

type TestARequest struct {
	Input string `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
	Id    int64  `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

func (*TestARequest) Descriptor 

func (*TestARequest) Descriptor() ([]byte, []int)

func (*TestARequest) GetId 

func (m *TestARequest) GetId() int64

func (*TestARequest) GetInput 

func (m *TestARequest) GetInput() string

func (*TestARequest) Marshal 

func (m *TestARequest) Marshal() (dAtA []byte, err error)

func (*TestARequest) MarshalTo 

func (m *TestARequest) MarshalTo(dAtA []byte) (int, error)

func (*TestARequest) MarshalToSizedBuffer 

func (m *TestARequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TestARequest) ProtoMessage 

func (*TestARequest) ProtoMessage()

func (*TestARequest) Reset 

func (m *TestARequest) Reset()

func (*TestARequest) Size 

func (m *TestARequest) Size() (n int)

func (*TestARequest) String 

func (m *TestARequest) String() string

func (*TestARequest) Unmarshal 

func (m *TestARequest) Unmarshal(dAtA []byte) error

func (*TestARequest) XXX_DiscardUnknown 

func (m *TestARequest) XXX_DiscardUnknown()

func (*TestARequest) XXX_Marshal 

func (m *TestARequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TestARequest) XXX_Merge 

func (m *TestARequest) XXX_Merge(src proto.Message)

func (*TestARequest) XXX_Size 

func (m *TestARequest) XXX_Size() int

func (*TestARequest) XXX_Unmarshal 

func (m *TestARequest) XXX_Unmarshal(b []byte) error

type TestAResponse 

type TestAResponse struct {
	Output string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Id     int64  `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

func (*TestAResponse) Descriptor 

func (*TestAResponse) Descriptor() ([]byte, []int)

func (*TestAResponse) GetId 

func (m *TestAResponse) GetId() int64

func (*TestAResponse) GetOutput 

func (m *TestAResponse) GetOutput() string

func (*TestAResponse) Marshal 

func (m *TestAResponse) Marshal() (dAtA []byte, err error)

func (*TestAResponse) MarshalTo 

func (m *TestAResponse) MarshalTo(dAtA []byte) (int, error)

func (*TestAResponse) MarshalToSizedBuffer 

func (m *TestAResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TestAResponse) ProtoMessage 

func (*TestAResponse) ProtoMessage()

func (*TestAResponse) Reset 

func (m *TestAResponse) Reset()

func (*TestAResponse) Size 

func (m *TestAResponse) Size() (n int)

func (*TestAResponse) String 

func (m *TestAResponse) String() string

func (*TestAResponse) Unmarshal 

func (m *TestAResponse) Unmarshal(dAtA []byte) error

func (*TestAResponse) XXX_DiscardUnknown 

func (m *TestAResponse) XXX_DiscardUnknown()

func (*TestAResponse) XXX_Marshal 

func (m *TestAResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TestAResponse) XXX_Merge 

func (m *TestAResponse) XXX_Merge(src proto.Message)

func (*TestAResponse) XXX_Size 

func (m *TestAResponse) XXX_Size() int

func (*TestAResponse) XXX_Unmarshal 

func (m *TestAResponse) XXX_Unmarshal(b []byte) error

type TestServiceClient 

type TestServiceClient interface {
	GetTestA(ctx context.Context, in *TestARequest, opts ...grpc.CallOption) (*TestAResponse, error)
	GetTestAB(ctx context.Context, in *TestARequest, opts ...grpc.CallOption) (*TestAResponse, error)
	FeedData(ctx context.Context, opts ...grpc.CallOption) (TestService_FeedDataClient, error)
	StreamData(ctx context.Context, in *StreamDataRequest, opts ...grpc.CallOption) (TestService_StreamDataClient, error)
	StreamDataAlt1(ctx context.Context, in *StreamDataRequest, opts ...grpc.CallOption) (TestService_StreamDataAlt1Client, error)
}

TestServiceClient is the client API for TestService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTestServiceClient 

func NewTestServiceClient(cc *grpc.ClientConn) TestServiceClient

type TestServiceGRPC 

type TestServiceGRPC struct {
	Context context.Context
	Bus     *protonats.Bus
	Service *TestServiceProtonatsClient
}

func NewTestServiceGRPC 

func NewTestServiceGRPC(ctx context.Context, config protonats.ServiceConfiguration) (*TestServiceGRPC, error)

func (*TestServiceGRPC) Close 

func (svc *TestServiceGRPC) Close()

func (*TestServiceGRPC) FeedData 

func (svc *TestServiceGRPC) FeedData(stream TestService_FeedDataServer) error

func (*TestServiceGRPC) GetTestA 

func (svc *TestServiceGRPC) GetTestA(ctx context.Context, req *TestARequest) (*TestAResponse, error)

func (*TestServiceGRPC) GetTestAB 

func (svc *TestServiceGRPC) GetTestAB(ctx context.Context, req *TestARequest) (*TestAResponse, error)

func (*TestServiceGRPC) StreamData 

func (svc *TestServiceGRPC) StreamData(req *StreamDataRequest, stream TestService_StreamDataServer) error

func (*TestServiceGRPC) StreamDataAlt1 

func (svc *TestServiceGRPC) StreamDataAlt1(req *StreamDataRequest, stream TestService_StreamDataAlt1Server) error

type TestServiceProtonatsClient 

type TestServiceProtonatsClient struct {
	Bus *protonats.Bus
}

func NewTestServiceProtonatsClient 

func NewTestServiceProtonatsClient(bus *protonats.Bus) *TestServiceProtonatsClient

func (*TestServiceProtonatsClient) FeedData 

func (service *TestServiceProtonatsClient) FeedData(ctx context.Context) (*TestServiceProtonatsClient_FeedData, error)

func (*TestServiceProtonatsClient) GetTestA 

func (service *TestServiceProtonatsClient) GetTestA(ctx context.Context, req *TestARequest) (*TestAResponse, error)

func (*TestServiceProtonatsClient) GetTestAB 

func (service *TestServiceProtonatsClient) GetTestAB(ctx context.Context, req *TestARequest) (*TestAResponse, error)

func (*TestServiceProtonatsClient) StreamData 

func (service *TestServiceProtonatsClient) StreamData(ctx context.Context, req *StreamDataRequest) (*TestServiceProtonatsClient_StreamData, error)

func (*TestServiceProtonatsClient) StreamDataAlt1 

func (service *TestServiceProtonatsClient) StreamDataAlt1(ctx context.Context, req *StreamDataRequest) (*TestServiceProtonatsClient_StreamDataAlt1, error)

type TestServiceProtonatsClient_FeedData 

type TestServiceProtonatsClient_FeedData struct {
	Context context.Context
	Service *TestServiceProtonatsClient
	ID      string
}

func (*TestServiceProtonatsClient_FeedData) Done 

func (client *TestServiceProtonatsClient_FeedData) Done() (*FeedDataResponse, error)

func (*TestServiceProtonatsClient_FeedData) Send 

func (client *TestServiceProtonatsClient_FeedData) Send(req *FeedDataRequest) error

type TestServiceProtonatsClient_StreamData 

type TestServiceProtonatsClient_StreamData struct {
	Context context.Context
	Service *TestServiceProtonatsClient
	ID      string
}

func (*TestServiceProtonatsClient_StreamData) Done 

func (client *TestServiceProtonatsClient_StreamData) Done() (*StreamDataResponse, error)

func (*TestServiceProtonatsClient_StreamData) Receive 

func (client *TestServiceProtonatsClient_StreamData) Receive() (*StreamDataResponse, error)

type TestServiceProtonatsClient_StreamDataAlt1 

type TestServiceProtonatsClient_StreamDataAlt1 struct {
	Context context.Context
	Service *TestServiceProtonatsClient
	ID      string
}

func (*TestServiceProtonatsClient_StreamDataAlt1) Done 

func (client *TestServiceProtonatsClient_StreamDataAlt1) Done() (*StreamDataResponse, error)

func (*TestServiceProtonatsClient_StreamDataAlt1) Receive 

func (client *TestServiceProtonatsClient_StreamDataAlt1) Receive() (*StreamDataResponse, error)

type TestServiceProtonatsInterface 

type TestServiceProtonatsInterface interface {
	GetTestA(ctx context.Context, req *TestARequest) (*TestAResponse, error)

	GetTestAB(ctx context.Context, req *TestARequest) (*TestAResponse, error)

	FeedData(stream TestService_FeedDataProtonatsServer)

	StreamData(req *StreamDataRequest, stream TestService_StreamDataProtonatsServer) error

	StreamDataAlt1(req *StreamDataRequest, stream TestService_StreamDataAlt1ProtonatsServer) error
}

type TestServiceProtonatsServer 

type TestServiceProtonatsServer struct {
	Bus     *protonats.Bus
	Service TestServiceProtonatsInterface
}

func NewTestServiceProtonatsServer 

func NewTestServiceProtonatsServer(bus *protonats.Bus, service TestServiceProtonatsInterface) *TestServiceProtonatsServer

func (*TestServiceProtonatsServer) SubscribeTestService 

func (service *TestServiceProtonatsServer) SubscribeTestService() (<-chan struct{}, error)

type TestServiceServer 

type TestServiceServer interface {
	GetTestA(context.Context, *TestARequest) (*TestAResponse, error)
	GetTestAB(context.Context, *TestARequest) (*TestAResponse, error)
	FeedData(TestService_FeedDataServer) error
	StreamData(*StreamDataRequest, TestService_StreamDataServer) error
	StreamDataAlt1(*StreamDataRequest, TestService_StreamDataAlt1Server) error
}

TestServiceServer is the server API for TestService service.

type TestService_FeedDataClient 

type TestService_FeedDataClient interface {
	Send(*FeedDataRequest) error
	CloseAndRecv() (*FeedDataResponse, error)
	grpc.ClientStream
}

type TestService_FeedDataProtonatsServer 

type TestService_FeedDataProtonatsServer interface {
	Receive() (*FeedDataRequest, error)
	OnData(*FeedDataRequest) error
	Done(resp *FeedDataResponse) error

	GetResponse() (*FeedDataResponse, error)

	TriggerEOF()
	Error(err error)
	OnExit(func())
	Exit()
}

type TestService_FeedDataProtonatsServerImpl 

type TestService_FeedDataProtonatsServerImpl struct {
	Context context.Context
	// contains filtered or unexported fields
}

func CreateTestService_FeedDataProtonatsServerImpl 

func CreateTestService_FeedDataProtonatsServerImpl(ctx context.Context) *TestService_FeedDataProtonatsServerImpl

func (*TestService_FeedDataProtonatsServerImpl) Cancel 

func (impl *TestService_FeedDataProtonatsServerImpl) Cancel()

func (*TestService_FeedDataProtonatsServerImpl) Done 

func (impl *TestService_FeedDataProtonatsServerImpl) Done(resp *FeedDataResponse) error

func (*TestService_FeedDataProtonatsServerImpl) Error 

func (impl *TestService_FeedDataProtonatsServerImpl) Error(err error)

func (*TestService_FeedDataProtonatsServerImpl) Exit 

func (impl *TestService_FeedDataProtonatsServerImpl) Exit()

func (*TestService_FeedDataProtonatsServerImpl) GetResponse 

func (impl *TestService_FeedDataProtonatsServerImpl) GetResponse() (*FeedDataResponse, error)

func (*TestService_FeedDataProtonatsServerImpl) OnData 

func (impl *TestService_FeedDataProtonatsServerImpl) OnData(req *FeedDataRequest) error

func (*TestService_FeedDataProtonatsServerImpl) OnExit 

func (impl *TestService_FeedDataProtonatsServerImpl) OnExit(fn func())

func (*TestService_FeedDataProtonatsServerImpl) Receive 

func (impl *TestService_FeedDataProtonatsServerImpl) Receive() (*FeedDataRequest, error)

func (*TestService_FeedDataProtonatsServerImpl) Subscribe 

func (impl *TestService_FeedDataProtonatsServerImpl) Subscribe(service *TestServiceProtonatsServer, id string) error

func (*TestService_FeedDataProtonatsServerImpl) TriggerEOF 

func (impl *TestService_FeedDataProtonatsServerImpl) TriggerEOF()

type TestService_FeedDataServer 

type TestService_FeedDataServer interface {
	SendAndClose(*FeedDataResponse) error
	Recv() (*FeedDataRequest, error)
	grpc.ServerStream
}

type TestService_StreamDataAlt1Client 

type TestService_StreamDataAlt1Client interface {
	Recv() (*StreamDataResponse, error)
	grpc.ClientStream
}

type TestService_StreamDataAlt1ProtonatsServer 

type TestService_StreamDataAlt1ProtonatsServer interface {
	GetResponse() (*StreamDataResponse, error)

	Send(*StreamDataResponse) error

	TriggerEOF()
	Error(err error)
	OnExit(func())
	Exit()
}

type TestService_StreamDataAlt1ProtonatsServerImpl 

type TestService_StreamDataAlt1ProtonatsServerImpl struct {
	Context context.Context
	// contains filtered or unexported fields
}

func CreateTestService_StreamDataAlt1ProtonatsServerImpl 

func CreateTestService_StreamDataAlt1ProtonatsServerImpl(ctx context.Context) *TestService_StreamDataAlt1ProtonatsServerImpl

func (*TestService_StreamDataAlt1ProtonatsServerImpl) Cancel 

func (impl *TestService_StreamDataAlt1ProtonatsServerImpl) Cancel()

func (*TestService_StreamDataAlt1ProtonatsServerImpl) Error 

func (impl *TestService_StreamDataAlt1ProtonatsServerImpl) Error(err error)

func (*TestService_StreamDataAlt1ProtonatsServerImpl) Exit 

func (impl *TestService_StreamDataAlt1ProtonatsServerImpl) Exit()

func (*TestService_StreamDataAlt1ProtonatsServerImpl) GetResponse 

func (impl *TestService_StreamDataAlt1ProtonatsServerImpl) GetResponse() (*StreamDataResponse, error)

func (*TestService_StreamDataAlt1ProtonatsServerImpl) OnExit 

func (impl *TestService_StreamDataAlt1ProtonatsServerImpl) OnExit(fn func())

func (*TestService_StreamDataAlt1ProtonatsServerImpl) Send 

func (impl *TestService_StreamDataAlt1ProtonatsServerImpl) Send(req *StreamDataResponse) error

func (*TestService_StreamDataAlt1ProtonatsServerImpl) Subscribe 

func (impl *TestService_StreamDataAlt1ProtonatsServerImpl) Subscribe(service *TestServiceProtonatsServer, id string) error

func (*TestService_StreamDataAlt1ProtonatsServerImpl) TriggerEOF 

func (impl *TestService_StreamDataAlt1ProtonatsServerImpl) TriggerEOF()

type TestService_StreamDataAlt1Server 

type TestService_StreamDataAlt1Server interface {
	Send(*StreamDataResponse) error
	grpc.ServerStream
}

type TestService_StreamDataClient 

type TestService_StreamDataClient interface {
	Recv() (*StreamDataResponse, error)
	grpc.ClientStream
}

type TestService_StreamDataProtonatsServer 

type TestService_StreamDataProtonatsServer interface {
	GetResponse() (*StreamDataResponse, error)

	Send(*StreamDataResponse) error

	TriggerEOF()
	Error(err error)
	OnExit(func())
	Exit()
}

type TestService_StreamDataProtonatsServerImpl 

type TestService_StreamDataProtonatsServerImpl struct {
	Context context.Context
	// contains filtered or unexported fields
}

func CreateTestService_StreamDataProtonatsServerImpl 

func CreateTestService_StreamDataProtonatsServerImpl(ctx context.Context) *TestService_StreamDataProtonatsServerImpl

func (*TestService_StreamDataProtonatsServerImpl) Cancel 

func (impl *TestService_StreamDataProtonatsServerImpl) Cancel()

func (*TestService_StreamDataProtonatsServerImpl) Error 

func (impl *TestService_StreamDataProtonatsServerImpl) Error(err error)

func (*TestService_StreamDataProtonatsServerImpl) Exit 

func (impl *TestService_StreamDataProtonatsServerImpl) Exit()

func (*TestService_StreamDataProtonatsServerImpl) GetResponse 

func (impl *TestService_StreamDataProtonatsServerImpl) GetResponse() (*StreamDataResponse, error)

func (*TestService_StreamDataProtonatsServerImpl) OnExit 

func (impl *TestService_StreamDataProtonatsServerImpl) OnExit(fn func())

func (*TestService_StreamDataProtonatsServerImpl) Send 

func (impl *TestService_StreamDataProtonatsServerImpl) Send(req *StreamDataResponse) error

func (*TestService_StreamDataProtonatsServerImpl) Subscribe 

func (impl *TestService_StreamDataProtonatsServerImpl) Subscribe(service *TestServiceProtonatsServer, id string) error

func (*TestService_StreamDataProtonatsServerImpl) TriggerEOF 

func (impl *TestService_StreamDataProtonatsServerImpl) TriggerEOF()

type TestService_StreamDataServer 

type TestService_StreamDataServer interface {
	Send(*StreamDataResponse) error
	grpc.ServerStream
}

type UnimplementedTestServiceServer 

type UnimplementedTestServiceServer struct {
}

UnimplementedTestServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTestServiceServer) FeedData 

func (*UnimplementedTestServiceServer) FeedData(srv TestService_FeedDataServer) error

func (*UnimplementedTestServiceServer) GetTestA 

func (*UnimplementedTestServiceServer) GetTestA(ctx context.Context, req *TestARequest) (*TestAResponse, error)

func (*UnimplementedTestServiceServer) GetTestAB 

func (*UnimplementedTestServiceServer) GetTestAB(ctx context.Context, req *TestARequest) (*TestAResponse, error)

func (*UnimplementedTestServiceServer) StreamData 

func (*UnimplementedTestServiceServer) StreamData(req *StreamDataRequest, srv TestService_StreamDataServer) error

func (*UnimplementedTestServiceServer) StreamDataAlt1 

func (*UnimplementedTestServiceServer) StreamDataAlt1(req *StreamDataRequest, srv TestService_StreamDataAlt1Server) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.