test

package
v0.1.5 Latest Latest
Warning

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

 Go to latest Published: May 22, 2020 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Overview

Code generated by github.com/citradigital/toldata. DO NOT EDIT. package: cdl.toldatatest source: toldata_test.proto

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthToldataTest = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowToldataTest   = 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)
	TestEmpty(ctx context.Context, in *toldata.Empty, opts ...grpc.CallOption) (*toldata.Empty, 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     *toldata.Bus
	Service *TestServiceToldataClient
}

func NewTestServiceGRPC 

func NewTestServiceGRPC(ctx context.Context, config toldata.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

func (*TestServiceGRPC) TestEmpty added in v0.1.2 

func (svc *TestServiceGRPC) TestEmpty(ctx context.Context, req *toldata.Empty) (*toldata.Empty, 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
	TestEmpty(context.Context, *toldata.Empty) (*toldata.Empty, error)
}

TestServiceServer is the server API for TestService service.

type TestServiceToldataClient 

type TestServiceToldataClient struct {
	Bus *toldata.Bus
}

func NewTestServiceToldataClient 

func NewTestServiceToldataClient(bus *toldata.Bus) *TestServiceToldataClient

func (*TestServiceToldataClient) FeedData 

func (service *TestServiceToldataClient) FeedData(ctx context.Context) (*TestServiceToldataClient_FeedData, error)

func (*TestServiceToldataClient) GetTestA 

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

func (*TestServiceToldataClient) GetTestAB 

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

func (*TestServiceToldataClient) StreamData 

func (service *TestServiceToldataClient) StreamData(ctx context.Context, req *StreamDataRequest) (*TestServiceToldataClient_StreamData, error)

func (*TestServiceToldataClient) StreamDataAlt1 

func (service *TestServiceToldataClient) StreamDataAlt1(ctx context.Context, req *StreamDataRequest) (*TestServiceToldataClient_StreamDataAlt1, error)

func (*TestServiceToldataClient) TestEmpty added in v0.1.2 

func (service *TestServiceToldataClient) TestEmpty(ctx context.Context, req *toldata.Empty) (*toldata.Empty, error)

func (*TestServiceToldataClient) ToldataHealthCheck added in v0.1.1 

func (service *TestServiceToldataClient) ToldataHealthCheck(ctx context.Context, req *toldata.Empty) (*toldata.ToldataHealthCheckInfo, error)

type TestServiceToldataClient_FeedData 

type TestServiceToldataClient_FeedData struct {
	Context context.Context
	Service *TestServiceToldataClient
	ID      string
}

func (*TestServiceToldataClient_FeedData) Done 

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

func (*TestServiceToldataClient_FeedData) Send 

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

type TestServiceToldataClient_StreamData 

type TestServiceToldataClient_StreamData struct {
	Context context.Context
	Service *TestServiceToldataClient
	ID      string
}

func (*TestServiceToldataClient_StreamData) Done 

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

func (*TestServiceToldataClient_StreamData) Receive 

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

type TestServiceToldataClient_StreamDataAlt1 

type TestServiceToldataClient_StreamDataAlt1 struct {
	Context context.Context
	Service *TestServiceToldataClient
	ID      string
}

func (*TestServiceToldataClient_StreamDataAlt1) Done 

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

func (*TestServiceToldataClient_StreamDataAlt1) Receive 

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

type TestServiceToldataInterface 

type TestServiceToldataInterface interface {
	ToldataHealthCheck(ctx context.Context, req *toldata.Empty) (*toldata.ToldataHealthCheckInfo, error)

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

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

	FeedData(stream TestService_FeedDataToldataServer)

	StreamData(req *StreamDataRequest, stream TestService_StreamDataToldataServer) error

	StreamDataAlt1(req *StreamDataRequest, stream TestService_StreamDataAlt1ToldataServer) error

	TestEmpty(ctx context.Context, req *toldata.Empty) (*toldata.Empty, error)
}

type TestServiceToldataServer 

type TestServiceToldataServer struct {
	Bus     *toldata.Bus
	Service TestServiceToldataInterface
}

func NewTestServiceToldataServer 

func NewTestServiceToldataServer(bus *toldata.Bus, service TestServiceToldataInterface) *TestServiceToldataServer

func (*TestServiceToldataServer) SubscribeTestService 

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

type TestService_FeedDataClient 

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

type TestService_FeedDataServer 

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

type TestService_FeedDataToldataServer 

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

	GetResponse() (*FeedDataResponse, error)

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

type TestService_FeedDataToldataServerImpl 

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

func CreateTestService_FeedDataToldataServerImpl 

func CreateTestService_FeedDataToldataServerImpl(ctx context.Context) *TestService_FeedDataToldataServerImpl

func (*TestService_FeedDataToldataServerImpl) Cancel 

func (impl *TestService_FeedDataToldataServerImpl) Cancel()

func (*TestService_FeedDataToldataServerImpl) Done 

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

func (*TestService_FeedDataToldataServerImpl) Error 

func (impl *TestService_FeedDataToldataServerImpl) Error(err error)

func (*TestService_FeedDataToldataServerImpl) Exit 

func (impl *TestService_FeedDataToldataServerImpl) Exit()

func (*TestService_FeedDataToldataServerImpl) GetResponse 

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

func (*TestService_FeedDataToldataServerImpl) OnData 

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

func (*TestService_FeedDataToldataServerImpl) OnExit 

func (impl *TestService_FeedDataToldataServerImpl) OnExit(fn func())

func (*TestService_FeedDataToldataServerImpl) Receive 

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

func (*TestService_FeedDataToldataServerImpl) Subscribe 

func (impl *TestService_FeedDataToldataServerImpl) Subscribe(service *TestServiceToldataServer, id string) error

func (*TestService_FeedDataToldataServerImpl) TriggerEOF 

func (impl *TestService_FeedDataToldataServerImpl) TriggerEOF()

type TestService_StreamDataAlt1Client 

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

type TestService_StreamDataAlt1Server 

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

type TestService_StreamDataAlt1ToldataServer 

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

	Send(*StreamDataResponse) error

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

type TestService_StreamDataAlt1ToldataServerImpl 

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

func CreateTestService_StreamDataAlt1ToldataServerImpl 

func CreateTestService_StreamDataAlt1ToldataServerImpl(ctx context.Context) *TestService_StreamDataAlt1ToldataServerImpl

func (*TestService_StreamDataAlt1ToldataServerImpl) Cancel 

func (impl *TestService_StreamDataAlt1ToldataServerImpl) Cancel()

func (*TestService_StreamDataAlt1ToldataServerImpl) Error 

func (impl *TestService_StreamDataAlt1ToldataServerImpl) Error(err error)

func (*TestService_StreamDataAlt1ToldataServerImpl) Exit 

func (impl *TestService_StreamDataAlt1ToldataServerImpl) Exit()

func (*TestService_StreamDataAlt1ToldataServerImpl) GetResponse 

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

func (*TestService_StreamDataAlt1ToldataServerImpl) OnExit 

func (impl *TestService_StreamDataAlt1ToldataServerImpl) OnExit(fn func())

func (*TestService_StreamDataAlt1ToldataServerImpl) Send 

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

func (*TestService_StreamDataAlt1ToldataServerImpl) Subscribe 

func (impl *TestService_StreamDataAlt1ToldataServerImpl) Subscribe(service *TestServiceToldataServer, id string) error

func (*TestService_StreamDataAlt1ToldataServerImpl) TriggerEOF 

func (impl *TestService_StreamDataAlt1ToldataServerImpl) TriggerEOF()

type TestService_StreamDataClient 

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

type TestService_StreamDataServer 

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

type TestService_StreamDataToldataServer 

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

	Send(*StreamDataResponse) error

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

type TestService_StreamDataToldataServerImpl 

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

func CreateTestService_StreamDataToldataServerImpl 

func CreateTestService_StreamDataToldataServerImpl(ctx context.Context) *TestService_StreamDataToldataServerImpl

func (*TestService_StreamDataToldataServerImpl) Cancel 

func (impl *TestService_StreamDataToldataServerImpl) Cancel()

func (*TestService_StreamDataToldataServerImpl) Error 

func (impl *TestService_StreamDataToldataServerImpl) Error(err error)

func (*TestService_StreamDataToldataServerImpl) Exit 

func (impl *TestService_StreamDataToldataServerImpl) Exit()

func (*TestService_StreamDataToldataServerImpl) GetResponse 

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

func (*TestService_StreamDataToldataServerImpl) OnExit 

func (impl *TestService_StreamDataToldataServerImpl) OnExit(fn func())

func (*TestService_StreamDataToldataServerImpl) Send 

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

func (*TestService_StreamDataToldataServerImpl) Subscribe 

func (impl *TestService_StreamDataToldataServerImpl) Subscribe(service *TestServiceToldataServer, id string) error

func (*TestService_StreamDataToldataServerImpl) TriggerEOF 

func (impl *TestService_StreamDataToldataServerImpl) TriggerEOF()

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

func (*UnimplementedTestServiceServer) TestEmpty added in v0.1.2 

func (*UnimplementedTestServiceServer) TestEmpty(ctx context.Context, req *toldata.Empty) (*toldata.Empty, 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.