test

type Bar struct {
	Bar string `protobuf:"bytes,1,opt,name=bar,proto3" json:"bar,omitempty"`
}

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

type Foo struct {
	Foo string `protobuf:"bytes,1,opt,name=foo,proto3" json:"foo,omitempty"`
}

type TestClient interface {
	Get(ctx context.Context, in *Foo, opts ...grpc.CallOption) (*Bar, error)
	Push(ctx context.Context, opts ...grpc.CallOption) (Test_PushClient, error)
	Pull(ctx context.Context, in *Foo, opts ...grpc.CallOption) (Test_PullClient, error)
	Sync(ctx context.Context, opts ...grpc.CallOption) (Test_SyncClient, error)
}

type TestServer interface {
	Get(context.Context, *Foo) (*Bar, error)
	Push(Test_PushServer) error
	Pull(*Foo, Test_PullServer) error
	Sync(Test_SyncServer) error
}

type TestServerImplementation struct {
	Token   string
	GetFoo  *Foo
	PushFoo *Foo
	PullFoo *Foo
	SyncFoo *Foo
	// contains filtered or unexported fields
}

type Test_PullClient interface {
	Recv() (*Bar, error)
	grpc.ClientStream
}

type Test_PullServer interface {
	Send(*Bar) error
	grpc.ServerStream
}

type Test_PushClient interface {
	Send(*Foo) error
	CloseAndRecv() (*Bar, error)
	grpc.ClientStream
}

type Test_PushServer interface {
	SendAndClose(*Bar) error
	Recv() (*Foo, error)
	grpc.ServerStream
}

type Test_SyncClient interface {
	Send(*Foo) error
	Recv() (*Bar, error)
	grpc.ClientStream
}

type Test_SyncServer interface {
	Send(*Bar) error
	Recv() (*Foo, error)
	grpc.ServerStream
}