proxy

Documentation

Index

• Variables
• func RegisterAPIServer(s *grpc.Server, srv APIServer)
• type APIClient
  • func NewAPIClient(cc *grpc.ClientConn) APIClient
• type APIServer
• type API_ListenClient
• type API_ListenServer
• type ListenRequest
  • func (*ListenRequest) Descriptor() ([]byte, []int)
  • func (m *ListenRequest) GetChannel() string
  • func (m *ListenRequest) Marshal() (dAtA []byte, err error)
  • func (x *ListenRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (m *ListenRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListenRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListenRequest) ProtoMessage()
  • func (m *ListenRequest) Reset()
  • func (m *ListenRequest) Size() (n int)
  • func (m *ListenRequest) String() string
  • func (m *ListenRequest) Unmarshal(dAtA []byte) error
  • func (m *ListenRequest) XXX_DiscardUnknown()
  • func (m *ListenRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListenRequest) XXX_Merge(src proto.Message)
  • func (m *ListenRequest) XXX_Size() int
  • func (m *ListenRequest) XXX_Unmarshal(b []byte) error
• type ListenResponse
  • func (*ListenResponse) Descriptor() ([]byte, []int)
  • func (m *ListenResponse) GetExtra() string
  • func (m *ListenResponse) Marshal() (dAtA []byte, err error)
  • func (x *ListenResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (m *ListenResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ListenResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ListenResponse) ProtoMessage()
  • func (m *ListenResponse) Reset()
  • func (m *ListenResponse) Size() (n int)
  • func (m *ListenResponse) String() string
  • func (m *ListenResponse) Unmarshal(dAtA []byte) error
  • func (m *ListenResponse) XXX_DiscardUnknown()
  • func (m *ListenResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ListenResponse) XXX_Merge(src proto.Message)
  • func (m *ListenResponse) XXX_Size() int
  • func (m *ListenResponse) XXX_Unmarshal(b []byte) error
• type UnimplementedAPIServer
  • func (*UnimplementedAPIServer) Listen(req *ListenRequest, srv API_ListenServer) error

Variables

var (
	ErrInvalidLengthProxy        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProxy          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProxy = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterAPIServer

func RegisterAPIServer(s *grpc.Server, srv APIServer)

Types

type APIClient

type APIClient interface {
	// Listen streams database events.
	// It signals that it is internally set up by sending an initial empty ListenResponse.
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (API_ListenClient, error)
}

APIClient is the client API for API service.

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

func NewAPIClient

func NewAPIClient(cc *grpc.ClientConn) APIClient

type APIServer

type APIServer interface {
	// Listen streams database events.
	// It signals that it is internally set up by sending an initial empty ListenResponse.
	Listen(*ListenRequest, API_ListenServer) error
}

APIServer is the server API for API service.

type API_ListenClient

type API_ListenClient interface {
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type API_ListenServer

type API_ListenServer interface {
	Send(*ListenResponse) error
	grpc.ServerStream
}

type ListenRequest

type ListenRequest struct {
	Channel              string   `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListenRequest) Descriptor

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

func (*ListenRequest) GetChannel

func (m *ListenRequest) GetChannel() string

func (*ListenRequest) Marshal

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

func (*ListenRequest) MarshalLogObject

func (x *ListenRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListenRequest) MarshalTo

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

func (*ListenRequest) MarshalToSizedBuffer

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

func (*ListenRequest) ProtoMessage

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) Reset

func (m *ListenRequest) Reset()

func (*ListenRequest) Size

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

func (*ListenRequest) String

func (m *ListenRequest) String() string

func (*ListenRequest) Unmarshal

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

func (*ListenRequest) XXX_DiscardUnknown

func (m *ListenRequest) XXX_DiscardUnknown()

func (*ListenRequest) XXX_Marshal

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

func (*ListenRequest) XXX_Merge

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

func (*ListenRequest) XXX_Size

func (m *ListenRequest) XXX_Size() int

func (*ListenRequest) XXX_Unmarshal

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

type ListenResponse

type ListenResponse struct {
	Extra                string   `protobuf:"bytes,1,opt,name=extra,proto3" json:"extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListenResponse) Descriptor

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

func (*ListenResponse) GetExtra

func (m *ListenResponse) GetExtra() string

func (*ListenResponse) Marshal

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

func (*ListenResponse) MarshalLogObject

func (x *ListenResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListenResponse) MarshalTo

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

func (*ListenResponse) MarshalToSizedBuffer

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

func (*ListenResponse) ProtoMessage

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) Reset

func (m *ListenResponse) Reset()

func (*ListenResponse) Size

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

func (*ListenResponse) String

func (m *ListenResponse) String() string

func (*ListenResponse) Unmarshal

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

func (*ListenResponse) XXX_DiscardUnknown

func (m *ListenResponse) XXX_DiscardUnknown()

func (*ListenResponse) XXX_Marshal

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

func (*ListenResponse) XXX_Merge

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

func (*ListenResponse) XXX_Size

func (m *ListenResponse) XXX_Size() int

func (*ListenResponse) XXX_Unmarshal

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

type UnimplementedAPIServer

type UnimplementedAPIServer struct {
}

UnimplementedAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAPIServer) Listen

func (*UnimplementedAPIServer) Listen(req *ListenRequest, srv API_ListenServer) error