channel

package
v0.0.0-...-12eefb5 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthChannel = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowChannel   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterChannelServiceServer 

func RegisterChannelServiceServer(s *grpc.Server, srv ChannelServiceServer)

Types

type ChannelServiceClient 

type ChannelServiceClient interface {
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Users(ctx context.Context, in *UsersRequest, opts ...grpc.CallOption) (*UsersResponse, error)
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	Leave(ctx context.Context, in *LeaveRequest, opts ...grpc.CallOption) (*LeaveResponse, error)
}

ChannelServiceClient is the client API for ChannelService service.

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

func NewChannelServiceClient 

func NewChannelServiceClient(cc *grpc.ClientConn) ChannelServiceClient

type ChannelServiceServer 

type ChannelServiceServer interface {
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Users(context.Context, *UsersRequest) (*UsersResponse, error)
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	Leave(context.Context, *LeaveRequest) (*LeaveResponse, error)
}

ChannelServiceServer is the server API for ChannelService service.

type CreateRequest 

type CreateRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
}

func (*CreateRequest) Descriptor 

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

func (*CreateRequest) Equal 

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

func (*CreateRequest) GetChannel 

func (m *CreateRequest) GetChannel() string

func (*CreateRequest) GoString 

func (this *CreateRequest) GoString() string

func (*CreateRequest) Marshal 

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

func (*CreateRequest) MarshalTo 

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

func (*CreateRequest) ProtoMessage 

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) Reset 

func (m *CreateRequest) Reset()

func (*CreateRequest) Size 

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

func (*CreateRequest) String 

func (this *CreateRequest) String() string

func (*CreateRequest) Unmarshal 

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

func (*CreateRequest) XXX_DiscardUnknown 

func (m *CreateRequest) XXX_DiscardUnknown()

func (*CreateRequest) XXX_Marshal 

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

func (*CreateRequest) XXX_Merge 

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

func (*CreateRequest) XXX_Size 

func (m *CreateRequest) XXX_Size() int

func (*CreateRequest) XXX_Unmarshal 

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

type CreateResponse 

type CreateResponse struct {
}

func (*CreateResponse) Descriptor 

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

func (*CreateResponse) Equal 

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

func (*CreateResponse) GoString 

func (this *CreateResponse) GoString() string

func (*CreateResponse) Marshal 

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

func (*CreateResponse) MarshalTo 

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

func (*CreateResponse) ProtoMessage 

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) Reset 

func (m *CreateResponse) Reset()

func (*CreateResponse) Size 

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

func (*CreateResponse) String 

func (this *CreateResponse) String() string

func (*CreateResponse) Unmarshal 

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

func (*CreateResponse) XXX_DiscardUnknown 

func (m *CreateResponse) XXX_DiscardUnknown()

func (*CreateResponse) XXX_Marshal 

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

func (*CreateResponse) XXX_Merge 

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

func (*CreateResponse) XXX_Size 

func (m *CreateResponse) XXX_Size() int

func (*CreateResponse) XXX_Unmarshal 

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

type DeleteRequest 

type DeleteRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) Equal 

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

func (*DeleteRequest) GetChannel 

func (m *DeleteRequest) GetChannel() string

func (*DeleteRequest) GoString 

func (this *DeleteRequest) GoString() string

func (*DeleteRequest) Marshal 

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

func (*DeleteRequest) MarshalTo 

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

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size 

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

func (*DeleteRequest) String 

func (this *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal 

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

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DeleteResponse 

type DeleteResponse struct {
}

func (*DeleteResponse) Descriptor 

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

func (*DeleteResponse) Equal 

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

func (*DeleteResponse) GoString 

func (this *DeleteResponse) GoString() string

func (*DeleteResponse) Marshal 

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

func (*DeleteResponse) MarshalTo 

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

func (*DeleteResponse) ProtoMessage 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size 

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

func (*DeleteResponse) String 

func (this *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal 

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

func (*DeleteResponse) XXX_DiscardUnknown 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal 

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

func (*DeleteResponse) XXX_Merge 

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

func (*DeleteResponse) XXX_Size 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal 

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

type JoinRequest 

type JoinRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
}

func (*JoinRequest) Descriptor 

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

func (*JoinRequest) Equal 

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

func (*JoinRequest) GetChannel 

func (m *JoinRequest) GetChannel() string

func (*JoinRequest) GoString 

func (this *JoinRequest) GoString() string

func (*JoinRequest) Marshal 

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

func (*JoinRequest) MarshalTo 

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

func (*JoinRequest) ProtoMessage 

func (*JoinRequest) ProtoMessage()

func (*JoinRequest) Reset 

func (m *JoinRequest) Reset()

func (*JoinRequest) Size 

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

func (*JoinRequest) String 

func (this *JoinRequest) String() string

func (*JoinRequest) Unmarshal 

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

func (*JoinRequest) XXX_DiscardUnknown 

func (m *JoinRequest) XXX_DiscardUnknown()

func (*JoinRequest) XXX_Marshal 

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

func (*JoinRequest) XXX_Merge 

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

func (*JoinRequest) XXX_Size 

func (m *JoinRequest) XXX_Size() int

func (*JoinRequest) XXX_Unmarshal 

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

type JoinResponse 

type JoinResponse struct {
}

func (*JoinResponse) Descriptor 

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

func (*JoinResponse) Equal 

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

func (*JoinResponse) GoString 

func (this *JoinResponse) GoString() string

func (*JoinResponse) Marshal 

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

func (*JoinResponse) MarshalTo 

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

func (*JoinResponse) ProtoMessage 

func (*JoinResponse) ProtoMessage()

func (*JoinResponse) Reset 

func (m *JoinResponse) Reset()

func (*JoinResponse) Size 

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

func (*JoinResponse) String 

func (this *JoinResponse) String() string

func (*JoinResponse) Unmarshal 

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

func (*JoinResponse) XXX_DiscardUnknown 

func (m *JoinResponse) XXX_DiscardUnknown()

func (*JoinResponse) XXX_Marshal 

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

func (*JoinResponse) XXX_Merge 

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

func (*JoinResponse) XXX_Size 

func (m *JoinResponse) XXX_Size() int

func (*JoinResponse) XXX_Unmarshal 

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

type LeaveRequest 

type LeaveRequest struct {
}

func (*LeaveRequest) Descriptor 

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

func (*LeaveRequest) Equal 

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

func (*LeaveRequest) GoString 

func (this *LeaveRequest) GoString() string

func (*LeaveRequest) Marshal 

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

func (*LeaveRequest) MarshalTo 

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

func (*LeaveRequest) ProtoMessage 

func (*LeaveRequest) ProtoMessage()

func (*LeaveRequest) Reset 

func (m *LeaveRequest) Reset()

func (*LeaveRequest) Size 

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

func (*LeaveRequest) String 

func (this *LeaveRequest) String() string

func (*LeaveRequest) Unmarshal 

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

func (*LeaveRequest) XXX_DiscardUnknown 

func (m *LeaveRequest) XXX_DiscardUnknown()

func (*LeaveRequest) XXX_Marshal 

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

func (*LeaveRequest) XXX_Merge 

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

func (*LeaveRequest) XXX_Size 

func (m *LeaveRequest) XXX_Size() int

func (*LeaveRequest) XXX_Unmarshal 

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

type LeaveResponse 

type LeaveResponse struct {
}

func (*LeaveResponse) Descriptor 

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

func (*LeaveResponse) Equal 

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

func (*LeaveResponse) GoString 

func (this *LeaveResponse) GoString() string

func (*LeaveResponse) Marshal 

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

func (*LeaveResponse) MarshalTo 

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

func (*LeaveResponse) ProtoMessage 

func (*LeaveResponse) ProtoMessage()

func (*LeaveResponse) Reset 

func (m *LeaveResponse) Reset()

func (*LeaveResponse) Size 

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

func (*LeaveResponse) String 

func (this *LeaveResponse) String() string

func (*LeaveResponse) Unmarshal 

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

func (*LeaveResponse) XXX_DiscardUnknown 

func (m *LeaveResponse) XXX_DiscardUnknown()

func (*LeaveResponse) XXX_Marshal 

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

func (*LeaveResponse) XXX_Merge 

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

func (*LeaveResponse) XXX_Size 

func (m *LeaveResponse) XXX_Size() int

func (*LeaveResponse) XXX_Unmarshal 

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

type ListRequest 

type ListRequest struct {
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) Equal 

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

func (*ListRequest) GoString 

func (this *ListRequest) GoString() string

func (*ListRequest) Marshal 

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

func (*ListRequest) MarshalTo 

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

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) Size 

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

func (*ListRequest) String 

func (this *ListRequest) String() string

func (*ListRequest) Unmarshal 

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

func (*ListRequest) XXX_DiscardUnknown 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal 

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

func (*ListRequest) XXX_Merge 

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

func (*ListRequest) XXX_Size 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal 

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

type ListResponse 

type ListResponse struct {
	Channels []string `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
}

func (*ListResponse) Descriptor 

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

func (*ListResponse) Equal 

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

func (*ListResponse) GetChannels 

func (m *ListResponse) GetChannels() []string

func (*ListResponse) GoString 

func (this *ListResponse) GoString() string

func (*ListResponse) Marshal 

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

func (*ListResponse) MarshalTo 

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

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) Size 

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

func (*ListResponse) String 

func (this *ListResponse) String() string

func (*ListResponse) Unmarshal 

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

func (*ListResponse) XXX_DiscardUnknown 

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal 

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

func (*ListResponse) XXX_Merge 

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

func (*ListResponse) XXX_Size 

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal 

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

type UsersRequest 

type UsersRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
}

func (*UsersRequest) Descriptor 

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

func (*UsersRequest) Equal 

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

func (*UsersRequest) GetChannel 

func (m *UsersRequest) GetChannel() string

func (*UsersRequest) GoString 

func (this *UsersRequest) GoString() string

func (*UsersRequest) Marshal 

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

func (*UsersRequest) MarshalTo 

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

func (*UsersRequest) ProtoMessage 

func (*UsersRequest) ProtoMessage()

func (*UsersRequest) Reset 

func (m *UsersRequest) Reset()

func (*UsersRequest) Size 

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

func (*UsersRequest) String 

func (this *UsersRequest) String() string

func (*UsersRequest) Unmarshal 

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

func (*UsersRequest) XXX_DiscardUnknown 

func (m *UsersRequest) XXX_DiscardUnknown()

func (*UsersRequest) XXX_Marshal 

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

func (*UsersRequest) XXX_Merge 

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

func (*UsersRequest) XXX_Size 

func (m *UsersRequest) XXX_Size() int

func (*UsersRequest) XXX_Unmarshal 

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

type UsersResponse 

type UsersResponse struct {
	Users []string `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
}

func (*UsersResponse) Descriptor 

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

func (*UsersResponse) Equal 

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

func (*UsersResponse) GetUsers 

func (m *UsersResponse) GetUsers() []string

func (*UsersResponse) GoString 

func (this *UsersResponse) GoString() string

func (*UsersResponse) Marshal 

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

func (*UsersResponse) MarshalTo 

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

func (*UsersResponse) ProtoMessage 

func (*UsersResponse) ProtoMessage()

func (*UsersResponse) Reset 

func (m *UsersResponse) Reset()

func (*UsersResponse) Size 

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

func (*UsersResponse) String 

func (this *UsersResponse) String() string

func (*UsersResponse) Unmarshal 

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

func (*UsersResponse) XXX_DiscardUnknown 

func (m *UsersResponse) XXX_DiscardUnknown()

func (*UsersResponse) XXX_Marshal 

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

func (*UsersResponse) XXX_Merge 

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

func (*UsersResponse) XXX_Size 

func (m *UsersResponse) XXX_Size() int

func (*UsersResponse) XXX_Unmarshal 

func (m *UsersResponse) XXX_Unmarshal(b []byte) 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.