test

Documentation

Overview

Package test is a generated protocol buffer package.

It is generated from these files:

test.proto

It has these top-level messages:

Foo
Bar

Index

• Variables
• func RegisterTestServer(s *grpc.Server, srv TestServer)
• type Bar
  • func (*Bar) Descriptor() ([]byte, []int)
  • func (this *Bar) Equal(that interface{}) bool
  • func (m *Bar) GetBar() string
  • func (this *Bar) GoString() string
  • func (m *Bar) Marshal() (dAtA []byte, err error)
  • func (m *Bar) MarshalTo(dAtA []byte) (int, error)
  • func (*Bar) ProtoMessage()
  • func (m *Bar) Reset()
  • func (m *Bar) Size() (n int)
  • func (this *Bar) String() string
  • func (m *Bar) Unmarshal(dAtA []byte) error
• type Cancel
  • func NewCancel() *Cancel
  • func (c *Cancel) Cancel()
  • func (c *Cancel) Interceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (stream grpc.ClientStream, err error)
• type Foo
  • func (*Foo) Descriptor() ([]byte, []int)
  • func (this *Foo) Equal(that interface{}) bool
  • func (m *Foo) GetFoo() string
  • func (this *Foo) GoString() string
  • func (m *Foo) Marshal() (dAtA []byte, err error)
  • func (m *Foo) MarshalTo(dAtA []byte) (int, error)
  • func (*Foo) ProtoMessage()
  • func (m *Foo) Reset()
  • func (m *Foo) Size() (n int)
  • func (this *Foo) String() string
  • func (m *Foo) Unmarshal(dAtA []byte) error
• type TestClient
  • func NewTestClient(cc *grpc.ClientConn) TestClient
• type TestServer
• type TestServerImplementation
  • func NewTestServer() *TestServerImplementation
  • func (s *TestServerImplementation) Get(ctx context.Context, foo *Foo) (*Bar, error)
  • func (s *TestServerImplementation) Pull(foo *Foo, stream Test_PullServer) (err error)
  • func (s *TestServerImplementation) Push(stream Test_PushServer) error
  • func (s *TestServerImplementation) Sync(stream Test_SyncServer) error
• type Test_PullClient
• type Test_PullServer
• type Test_PushClient
• type Test_PushServer
• type Test_SyncClient
• type Test_SyncServer

Variables

var (
	ErrInvalidLengthTest = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTest   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterTestServer

func RegisterTestServer(s *grpc.Server, srv TestServer)

Types

type Bar

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

func (*Bar) Descriptor

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

func (*Bar) Equal

func (this *Bar) Equal(that interface{}) bool

func (*Bar) GetBar

func (m *Bar) GetBar() string

func (*Bar) GoString

func (this *Bar) GoString() string

func (*Bar) Marshal

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

func (*Bar) MarshalTo

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

func (*Bar) ProtoMessage

func (*Bar) ProtoMessage()

func (*Bar) Reset

func (m *Bar) Reset()

func (*Bar) Size

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

func (*Bar) String

func (this *Bar) String() string

func (*Bar) Unmarshal

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

type Cancel

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

func NewCancel

func NewCancel() *Cancel

func (*Cancel) Cancel

func (c *Cancel) Cancel()

func (*Cancel) Interceptor

func (c *Cancel) Interceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (stream grpc.ClientStream, err error)

type Foo

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

func (*Foo) Descriptor

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

func (*Foo) Equal

func (this *Foo) Equal(that interface{}) bool

func (*Foo) GetFoo

func (m *Foo) GetFoo() string

func (*Foo) GoString

func (this *Foo) GoString() string

func (*Foo) Marshal

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

func (*Foo) MarshalTo

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

func (*Foo) ProtoMessage

func (*Foo) ProtoMessage()

func (*Foo) Reset

func (m *Foo) Reset()

func (*Foo) Size

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

func (*Foo) String

func (this *Foo) String() string

func (*Foo) Unmarshal

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

type TestClient

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)
}

func NewTestClient

func NewTestClient(cc *grpc.ClientConn) TestClient

type TestServer

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

type TestServerImplementation

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

func NewTestServer

func NewTestServer() *TestServerImplementation

func (*TestServerImplementation) Get

func (s *TestServerImplementation) Get(ctx context.Context, foo *Foo) (*Bar, error)

func (*TestServerImplementation) Pull

func (s *TestServerImplementation) Pull(foo *Foo, stream Test_PullServer) (err error)

func (*TestServerImplementation) Push

func (s *TestServerImplementation) Push(stream Test_PushServer) error

func (*TestServerImplementation) Sync

func (s *TestServerImplementation) Sync(stream Test_SyncServer) error

type Test_PullClient

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

type Test_PullServer

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

type Test_PushClient

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

type Test_PushServer

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

type Test_SyncClient

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

type Test_SyncServer

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