test

type Empty struct {
	// contains filtered or unexported fields
}

type FeedDataRequest struct {
	Data int64 `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type FeedDataResponse struct {
	Sum int64 `protobuf:"varint,1,opt,name=sum,proto3" json:"sum,omitempty"`
	// contains filtered or unexported fields
}

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
}

type StreamDataRequest struct {
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type StreamDataResponse struct {
	Data int64 `protobuf:"varint,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

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"`
	// contains filtered or unexported fields
}

type TestGetIPResponse struct {
	Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

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)
	GetTestGetIP(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*TestGetIPResponse, 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 *Empty, opts ...grpc.CallOption) (*Empty, error)
}

type TestServiceGRPC struct {
	UnimplementedTestServiceServer
	Context context.Context
	Bus     *toldata.Bus
	Service *TestServiceToldataClient
}

type TestServiceREST struct {
	Context context.Context
	Bus     *toldata.Bus
	Service *TestServiceToldataClient
}

type TestServiceServer interface {
	GetTestA(context.Context, *TestARequest) (*TestAResponse, error)
	GetTestAB(context.Context, *TestARequest) (*TestAResponse, error)
	GetTestGetIP(context.Context, *Empty) (*TestGetIPResponse, error)
	FeedData(TestService_FeedDataServer) error
	StreamData(*StreamDataRequest, TestService_StreamDataServer) error
	StreamDataAlt1(*StreamDataRequest, TestService_StreamDataAlt1Server) error
	TestEmpty(context.Context, *Empty) (*Empty, error)
	// contains filtered or unexported methods
}

type TestServiceToldataClient struct {
	Bus *toldata.Bus
}

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

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

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

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)

	GetTestGetIP(ctx context.Context, req *Empty) (*TestGetIPResponse, error)

	FeedData(stream TestService_FeedDataToldataServer)

	StreamData(req *StreamDataRequest, stream TestService_StreamDataToldataServer) error

	StreamDataAlt1(req *StreamDataRequest, stream TestService_StreamDataAlt1ToldataServer) error

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

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

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

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

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 struct {
	Context context.Context
	// contains filtered or unexported fields
}

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

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

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

	Send(*StreamDataResponse) error

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

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

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

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

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

	Send(*StreamDataResponse) error

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

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

type UnimplementedTestServiceServer struct {
}

type UnsafeTestServiceServer interface {
	// contains filtered or unexported methods
}