chatgroup

package

v0.0.0-...-f8f499d Latest Latest Go to latest Published: Sep 18, 2019 License: MIT Imports: 5 Imported by: 0

Documentation ¶

Index ¶

func RegisterDisplayerServer(s *grpc.Server, srv DisplayerServer)
func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)
type DisplayerClient
- func NewDisplayerClient(cc *grpc.ClientConn) DisplayerClient
type DisplayerServer
type Member
type MemberList
type Message
type PublisherClient
- func NewPublisherClient(cc *grpc.ClientConn) PublisherClient
type PublisherServer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func RegisterDisplayerServer ¶

func RegisterDisplayerServer(s *grpc.Server, srv DisplayerServer)

func RegisterPublisherServer ¶

func RegisterPublisherServer(s *grpc.Server, srv PublisherServer)

Types ¶

type DisplayerClient ¶

type DisplayerClient interface {
	DisplayText(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Message, error)
	DisplaySubscription(ctx context.Context, in *Member, opts ...grpc.CallOption) (*Member, error)
	DisplayUnsubscription(ctx context.Context, in *Member, opts ...grpc.CallOption) (*Member, error)
}

DisplayerClient is the client API for Displayer service.

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

func NewDisplayerClient ¶

func NewDisplayerClient(cc *grpc.ClientConn) DisplayerClient

type DisplayerServer ¶

type DisplayerServer interface {
	DisplayText(context.Context, *Message) (*Message, error)
	DisplaySubscription(context.Context, *Member) (*Member, error)
	DisplayUnsubscription(context.Context, *Member) (*Member, error)
}

DisplayerServer is the server API for Displayer service.

type Member ¶

type Member struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Ip                   string   `protobuf:"bytes,2,opt,name=ip" json:"ip,omitempty"`
	Port                 string   `protobuf:"bytes,3,opt,name=port" json:"port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Member) Descriptor ¶

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

func (*Member) GetIp ¶

func (m *Member) GetIp() string

func (*Member) GetName ¶

func (m *Member) GetName() string

func (*Member) GetPort ¶

func (m *Member) GetPort() string

func (*Member) ProtoMessage ¶

func (*Member) ProtoMessage()

func (*Member) Reset ¶

func (m *Member) Reset()

func (*Member) String ¶

func (m *Member) String() string

func (*Member) XXX_DiscardUnknown ¶

func (m *Member) XXX_DiscardUnknown()

func (*Member) XXX_Marshal ¶

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

func (*Member) XXX_Merge ¶

func (dst *Member) XXX_Merge(src proto.Message)

func (*Member) XXX_Size ¶

func (m *Member) XXX_Size() int

func (*Member) XXX_Unmarshal ¶

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

type MemberList ¶

type MemberList struct {
	Member               []*Member `protobuf:"bytes,1,rep,name=member" json:"member,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*MemberList) Descriptor ¶

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

func (*MemberList) GetMember ¶

func (m *MemberList) GetMember() []*Member

func (*MemberList) ProtoMessage ¶

func (*MemberList) ProtoMessage()

func (*MemberList) Reset ¶

func (m *MemberList) Reset()

func (*MemberList) String ¶

func (m *MemberList) String() string

func (*MemberList) XXX_DiscardUnknown ¶

func (m *MemberList) XXX_DiscardUnknown()

func (*MemberList) XXX_Marshal ¶

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

func (*MemberList) XXX_Merge ¶

func (dst *MemberList) XXX_Merge(src proto.Message)

func (*MemberList) XXX_Size ¶

func (m *MemberList) XXX_Size() int

func (*MemberList) XXX_Unmarshal ¶

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

type Message ¶

type Message struct {
	Sender               *Member  `protobuf:"bytes,1,opt,name=sender" json:"sender,omitempty"`
	Text                 string   `protobuf:"bytes,2,opt,name=text" json:"text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Message) Descriptor ¶

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

func (*Message) GetSender ¶

func (m *Message) GetSender() *Member

func (*Message) GetText ¶

func (m *Message) GetText() string

func (*Message) ProtoMessage ¶

func (*Message) ProtoMessage()

func (*Message) Reset ¶

func (m *Message) Reset()

func (*Message) String ¶

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown ¶

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal ¶

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

func (*Message) XXX_Merge ¶

func (dst *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size ¶

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal ¶

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

type PublisherClient ¶

type PublisherClient interface {
	Subscribe(ctx context.Context, in *Member, opts ...grpc.CallOption) (*Member, error)
	Unsubscribe(ctx context.Context, in *Member, opts ...grpc.CallOption) (*Member, error)
	Publish(ctx context.Context, in *Message, opts ...grpc.CallOption) (*MemberList, error)
}

PublisherClient is the client API for Publisher service.

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

func NewPublisherClient ¶

func NewPublisherClient(cc *grpc.ClientConn) PublisherClient

type PublisherServer ¶

type PublisherServer interface {
	Subscribe(context.Context, *Member) (*Member, error)
	Unsubscribe(context.Context, *Member) (*Member, error)
	Publish(context.Context, *Message) (*MemberList, error)
}

PublisherServer is the server API for Publisher service.

Source Files ¶

chat-group.pb.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL