pb

package
v0.0.51 Latest Latest
Warning

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

 Go to latest Published: Jul 7, 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) Close 

func (c *Client) Close(ctx context.Context) error

func (*Client) CloseSession 

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

func (*Client) Publish 

func (c *Client) Publish(ctx context.Context, id string, publish *packet.Publish) 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 CloseSessionInput 

type CloseSessionInput 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 (*CloseSessionInput) Descriptor 

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

func (*CloseSessionInput) GetID 

func (m *CloseSessionInput) GetID() string

func (*CloseSessionInput) ProtoMessage 

func (*CloseSessionInput) ProtoMessage()

func (*CloseSessionInput) Reset 

func (m *CloseSessionInput) Reset()

func (*CloseSessionInput) String 

func (m *CloseSessionInput) String() string

func (*CloseSessionInput) XXX_DiscardUnknown 

func (m *CloseSessionInput) XXX_DiscardUnknown()

func (*CloseSessionInput) XXX_Marshal 

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

func (*CloseSessionInput) XXX_Merge 

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

func (*CloseSessionInput) XXX_Size 

func (m *CloseSessionInput) XXX_Size() int

func (*CloseSessionInput) XXX_Unmarshal 

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

type CloseSessionOutput 

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

func (*CloseSessionOutput) Descriptor 

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

func (*CloseSessionOutput) ProtoMessage 

func (*CloseSessionOutput) ProtoMessage()

func (*CloseSessionOutput) Reset 

func (m *CloseSessionOutput) Reset()

func (*CloseSessionOutput) String 

func (m *CloseSessionOutput) String() string

func (*CloseSessionOutput) XXX_DiscardUnknown 

func (m *CloseSessionOutput) XXX_DiscardUnknown()

func (*CloseSessionOutput) XXX_Marshal 

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

func (*CloseSessionOutput) XXX_Merge 

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

func (*CloseSessionOutput) XXX_Size 

func (m *CloseSessionOutput) XXX_Size() int

func (*CloseSessionOutput) XXX_Unmarshal 

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

type ListenerServiceClient 

type ListenerServiceClient interface {
	Publish(ctx context.Context, in *PublishInput, opts ...grpc.CallOption) (*PublishOutput, error)
	CloseSession(ctx context.Context, in *CloseSessionInput, opts ...grpc.CallOption) (*CloseSessionOutput, error)
	Close(ctx context.Context, in *CloseInput, opts ...grpc.CallOption) (*CloseOutput, 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 {
	Publish(context.Context, *PublishInput) (*PublishOutput, error)
	CloseSession(context.Context, *CloseSessionInput) (*CloseSessionOutput, error)
	Close(context.Context, *CloseInput) (*CloseOutput, error)
}

ListenerServiceServer is the server API for ListenerService service.

type PublishInput 

type PublishInput 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 (*PublishInput) Descriptor 

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

func (*PublishInput) GetID 

func (m *PublishInput) GetID() string

func (*PublishInput) GetPublish 

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

func (*PublishInput) ProtoMessage 

func (*PublishInput) ProtoMessage()

func (*PublishInput) Reset 

func (m *PublishInput) Reset()

func (*PublishInput) String 

func (m *PublishInput) String() string

func (*PublishInput) XXX_DiscardUnknown 

func (m *PublishInput) XXX_DiscardUnknown()

func (*PublishInput) XXX_Marshal 

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

func (*PublishInput) XXX_Merge 

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

func (*PublishInput) XXX_Size 

func (m *PublishInput) XXX_Size() int

func (*PublishInput) XXX_Unmarshal 

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

type PublishOutput 

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

func (*PublishOutput) Descriptor 

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

func (*PublishOutput) ProtoMessage 

func (*PublishOutput) ProtoMessage()

func (*PublishOutput) Reset 

func (m *PublishOutput) Reset()

func (*PublishOutput) String 

func (m *PublishOutput) String() string

func (*PublishOutput) XXX_DiscardUnknown 

func (m *PublishOutput) XXX_DiscardUnknown()

func (*PublishOutput) XXX_Marshal 

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

func (*PublishOutput) XXX_Merge 

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

func (*PublishOutput) XXX_Size 

func (m *PublishOutput) XXX_Size() int

func (*PublishOutput) XXX_Unmarshal 

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

type UnimplementedListenerServiceServer 

type UnimplementedListenerServiceServer struct {
}

UnimplementedListenerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedListenerServiceServer) Close 

func (*UnimplementedListenerServiceServer) Close(ctx context.Context, req *CloseInput) (*CloseOutput, error)

func (*UnimplementedListenerServiceServer) CloseSession 

func (*UnimplementedListenerServiceServer) CloseSession(ctx context.Context, req *CloseSessionInput) (*CloseSessionOutput, error)

func (*UnimplementedListenerServiceServer) Publish 

func (*UnimplementedListenerServiceServer) Publish(ctx context.Context, req *PublishInput) (*PublishOutput, 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.