pb

package
v0.0.63-rc9 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2019 License: MPL-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterListenerServiceServer 

func RegisterListenerServiceServer(s *grpc.Server, srv ListenerServiceServer)

Types

type Client 

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

func NewClient 

func NewClient(conn *grpc.ClientConn) *Client

func (*Client) SendPublish added in v0.0.56 

func (c *Client) SendPublish(ctx context.Context, id string, publish *packet.Publish) error

func (*Client) Shutdown added in v0.0.56 

func (c *Client) Shutdown(ctx context.Context, id string) error

type CloseInput 

type CloseInput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseInput) Descriptor 

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

func (*CloseInput) ProtoMessage 

func (*CloseInput) ProtoMessage()

func (*CloseInput) Reset 

func (m *CloseInput) Reset()

func (*CloseInput) String 

func (m *CloseInput) String() string

func (*CloseInput) XXX_DiscardUnknown 

func (m *CloseInput) XXX_DiscardUnknown()

func (*CloseInput) XXX_Marshal 

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

func (*CloseInput) XXX_Merge 

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

func (*CloseInput) XXX_Size 

func (m *CloseInput) XXX_Size() int

func (*CloseInput) XXX_Unmarshal 

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

type CloseOutput 

type CloseOutput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CloseOutput) Descriptor 

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

func (*CloseOutput) ProtoMessage 

func (*CloseOutput) ProtoMessage()

func (*CloseOutput) Reset 

func (m *CloseOutput) Reset()

func (*CloseOutput) String 

func (m *CloseOutput) String() string

func (*CloseOutput) XXX_DiscardUnknown 

func (m *CloseOutput) XXX_DiscardUnknown()

func (*CloseOutput) XXX_Marshal 

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

func (*CloseOutput) XXX_Merge 

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

func (*CloseOutput) XXX_Size 

func (m *CloseOutput) XXX_Size() int

func (*CloseOutput) XXX_Unmarshal 

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

type ListenerServiceClient 

type ListenerServiceClient interface {
	SendPublish(ctx context.Context, in *SendPublishInput, opts ...grpc.CallOption) (*SendPublishOutput, error)
	Shutdown(ctx context.Context, in *ShutdownInput, opts ...grpc.CallOption) (*ShutdownOutput, error)
}

ListenerServiceClient is the client API for ListenerService service.

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

func NewListenerServiceClient 

func NewListenerServiceClient(cc *grpc.ClientConn) ListenerServiceClient

type ListenerServiceServer 

type ListenerServiceServer interface {
	SendPublish(context.Context, *SendPublishInput) (*SendPublishOutput, error)
	Shutdown(context.Context, *ShutdownInput) (*ShutdownOutput, error)
}

ListenerServiceServer is the server API for ListenerService service.

type SendPublishInput added in v0.0.56 

type SendPublishInput struct {
	ID                   string          `protobuf:"bytes,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Publish              *packet.Publish `protobuf:"bytes,2,opt,name=Publish,proto3" json:"Publish,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*SendPublishInput) Descriptor added in v0.0.56 

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

func (*SendPublishInput) GetID added in v0.0.56 

func (m *SendPublishInput) GetID() string

func (*SendPublishInput) GetPublish added in v0.0.56 

func (m *SendPublishInput) GetPublish() *packet.Publish

func (*SendPublishInput) ProtoMessage added in v0.0.56 

func (*SendPublishInput) ProtoMessage()

func (*SendPublishInput) Reset added in v0.0.56 

func (m *SendPublishInput) Reset()

func (*SendPublishInput) String added in v0.0.56 

func (m *SendPublishInput) String() string

func (*SendPublishInput) XXX_DiscardUnknown added in v0.0.56 

func (m *SendPublishInput) XXX_DiscardUnknown()

func (*SendPublishInput) XXX_Marshal added in v0.0.56 

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

func (*SendPublishInput) XXX_Merge added in v0.0.56 

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

func (*SendPublishInput) XXX_Size added in v0.0.56 

func (m *SendPublishInput) XXX_Size() int

func (*SendPublishInput) XXX_Unmarshal added in v0.0.56 

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

type SendPublishOutput added in v0.0.56 

type SendPublishOutput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SendPublishOutput) Descriptor added in v0.0.56 

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

func (*SendPublishOutput) ProtoMessage added in v0.0.56 

func (*SendPublishOutput) ProtoMessage()

func (*SendPublishOutput) Reset added in v0.0.56 

func (m *SendPublishOutput) Reset()

func (*SendPublishOutput) String added in v0.0.56 

func (m *SendPublishOutput) String() string

func (*SendPublishOutput) XXX_DiscardUnknown added in v0.0.56 

func (m *SendPublishOutput) XXX_DiscardUnknown()

func (*SendPublishOutput) XXX_Marshal added in v0.0.56 

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

func (*SendPublishOutput) XXX_Merge added in v0.0.56 

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

func (*SendPublishOutput) XXX_Size added in v0.0.56 

func (m *SendPublishOutput) XXX_Size() int

func (*SendPublishOutput) XXX_Unmarshal added in v0.0.56 

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

type ShutdownInput added in v0.0.56 

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

func (*ShutdownInput) Descriptor added in v0.0.56 

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

func (*ShutdownInput) GetID added in v0.0.56 

func (m *ShutdownInput) GetID() string

func (*ShutdownInput) ProtoMessage added in v0.0.56 

func (*ShutdownInput) ProtoMessage()

func (*ShutdownInput) Reset added in v0.0.56 

func (m *ShutdownInput) Reset()

func (*ShutdownInput) String added in v0.0.56 

func (m *ShutdownInput) String() string

func (*ShutdownInput) XXX_DiscardUnknown added in v0.0.56 

func (m *ShutdownInput) XXX_DiscardUnknown()

func (*ShutdownInput) XXX_Marshal added in v0.0.56 

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

func (*ShutdownInput) XXX_Merge added in v0.0.56 

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

func (*ShutdownInput) XXX_Size added in v0.0.56 

func (m *ShutdownInput) XXX_Size() int

func (*ShutdownInput) XXX_Unmarshal added in v0.0.56 

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

type ShutdownOutput added in v0.0.56 

type ShutdownOutput struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ShutdownOutput) Descriptor added in v0.0.56 

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

func (*ShutdownOutput) ProtoMessage added in v0.0.56 

func (*ShutdownOutput) ProtoMessage()

func (*ShutdownOutput) Reset added in v0.0.56 

func (m *ShutdownOutput) Reset()

func (*ShutdownOutput) String added in v0.0.56 

func (m *ShutdownOutput) String() string

func (*ShutdownOutput) XXX_DiscardUnknown added in v0.0.56 

func (m *ShutdownOutput) XXX_DiscardUnknown()

func (*ShutdownOutput) XXX_Marshal added in v0.0.56 

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

func (*ShutdownOutput) XXX_Merge added in v0.0.56 

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

func (*ShutdownOutput) XXX_Size added in v0.0.56 

func (m *ShutdownOutput) XXX_Size() int

func (*ShutdownOutput) XXX_Unmarshal added in v0.0.56 

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

type UnimplementedListenerServiceServer 

type UnimplementedListenerServiceServer struct {
}

UnimplementedListenerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedListenerServiceServer) SendPublish added in v0.0.56 

func (*UnimplementedListenerServiceServer) SendPublish(ctx context.Context, req *SendPublishInput) (*SendPublishOutput, error)

func (*UnimplementedListenerServiceServer) Shutdown added in v0.0.56 

func (*UnimplementedListenerServiceServer) Shutdown(ctx context.Context, req *ShutdownInput) (*ShutdownOutput, 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.