servicepb

Documentation

Index

• Variables
• func RegisterBroadcastServer(s *grpc.Server, srv BroadcastServer)
• type BroadcastClient
  • func NewBroadcastClient(cc grpc.ClientConnInterface) BroadcastClient
• type BroadcastServer
• type Broadcast_CreateStreamClient
• type Broadcast_CreateStreamServer
• type Close
  • func (*Close) Descriptor() ([]byte, []int)
  • func (*Close) ProtoMessage()
  • func (x *Close) ProtoReflect() protoreflect.Message
  • func (x *Close) Reset()
  • func (x *Close) String() string
• type Connect
  • func (*Connect) Descriptor() ([]byte, []int)
  • func (x *Connect) GetActive() bool
  • func (x *Connect) GetUser() *User
  • func (*Connect) ProtoMessage()
  • func (x *Connect) ProtoReflect() protoreflect.Message
  • func (x *Connect) Reset()
  • func (x *Connect) String() string
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (x *Message) GetContent() string
  • func (x *Message) GetId() string
  • func (x *Message) GetTimestamp() string
  • func (*Message) ProtoMessage()
  • func (x *Message) ProtoReflect() protoreflect.Message
  • func (x *Message) Reset()
  • func (x *Message) String() string
• type UnimplementedBroadcastServer
  • func (*UnimplementedBroadcastServer) BroadcastMessage(context.Context, *Message) (*Close, error)
  • func (*UnimplementedBroadcastServer) CreateStream(*Connect, Broadcast_CreateStreamServer) error
• type User
  • func (*User) Descriptor() ([]byte, []int)
  • func (x *User) GetId() string
  • func (x *User) GetName() string
  • func (*User) ProtoMessage()
  • func (x *User) ProtoReflect() protoreflect.Message
  • func (x *User) Reset()
  • func (x *User) String() string

Variables

var File_service_proto protoreflect.FileDescriptor

Functions

func RegisterBroadcastServer

func RegisterBroadcastServer(s *grpc.Server, srv BroadcastServer)

Types

type BroadcastClient

type BroadcastClient interface {
	CreateStream(ctx context.Context, in *Connect, opts ...grpc.CallOption) (Broadcast_CreateStreamClient, error)
	BroadcastMessage(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Close, error)
}

BroadcastClient is the client API for Broadcast service.

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

func NewBroadcastClient

func NewBroadcastClient(cc grpc.ClientConnInterface) BroadcastClient

type BroadcastServer

type BroadcastServer interface {
	CreateStream(*Connect, Broadcast_CreateStreamServer) error
	BroadcastMessage(context.Context, *Message) (*Close, error)
}

BroadcastServer is the server API for Broadcast service.

type Broadcast_CreateStreamClient

type Broadcast_CreateStreamClient interface {
	Recv() (*Message, error)
	grpc.ClientStream
}

type Broadcast_CreateStreamServer

type Broadcast_CreateStreamServer interface {
	Send(*Message) error
	grpc.ServerStream
}

type Close

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

func (*Close) Descriptor

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

Deprecated: Use Close.ProtoReflect.Descriptor instead.

func (*Close) ProtoMessage

func (*Close) ProtoMessage()

func (*Close) ProtoReflect

func (x *Close) ProtoReflect() protoreflect.Message

func (*Close) Reset

func (x *Close) Reset()

func (*Close) String

func (x *Close) String() string

type Connect

type Connect struct {
	User   *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Active bool  `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	// contains filtered or unexported fields
}

func (*Connect) Descriptor

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

Deprecated: Use Connect.ProtoReflect.Descriptor instead.

func (*Connect) GetActive

func (x *Connect) GetActive() bool

func (*Connect) GetUser

func (x *Connect) GetUser() *User

func (*Connect) ProtoMessage

func (*Connect) ProtoMessage()

func (*Connect) ProtoReflect

func (x *Connect) ProtoReflect() protoreflect.Message

func (*Connect) Reset

func (x *Connect) Reset()

func (*Connect) String

func (x *Connect) String() string

type Message

type Message struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Content   string `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	Timestamp string `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetContent

func (x *Message) GetContent() string

func (*Message) GetId

func (x *Message) GetId() string

func (*Message) GetTimestamp

func (x *Message) GetTimestamp() string

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

type UnimplementedBroadcastServer

type UnimplementedBroadcastServer struct {
}

UnimplementedBroadcastServer can be embedded to have forward compatible implementations.

func (*UnimplementedBroadcastServer) BroadcastMessage

func (*UnimplementedBroadcastServer) BroadcastMessage(context.Context, *Message) (*Close, error)

func (*UnimplementedBroadcastServer) CreateStream

func (*UnimplementedBroadcastServer) CreateStream(*Connect, Broadcast_CreateStreamServer) error

type User

type User struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*User) Descriptor

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetId

func (x *User) GetId() string

func (*User) GetName

func (x *User) GetName() string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) ProtoReflect

func (x *User) ProtoReflect() protoreflect.Message

func (*User) Reset

func (x *User) Reset()

func (*User) String

func (x *User) String() string