pb

package
v0.0.7 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMessageServer 

func RegisterMessageServer(s *grpc.Server, srv MessageServer)

func RegisterMiddleServer 

func RegisterMiddleServer(s *grpc.Server, srv MiddleServer)

func RegisterSubscribeServer 

func RegisterSubscribeServer(s *grpc.Server, srv SubscribeServer)

Types

type MessageClient 

type MessageClient interface {
	List(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageList, error)
	Get(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageReply, error)
	Create(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageList, error)
	Delete(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageReply, error)
	Send(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageReply, error)
	Run(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageReply, error)
}

MessageClient is the client API for Message service.

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

func NewMessageClient 

func NewMessageClient(cc *grpc.ClientConn) MessageClient

type MessageList 

type MessageList struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Text                 []string `protobuf:"bytes,2,rep,name=text,proto3" json:"text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageList) Descriptor 

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

func (*MessageList) GetText 

func (m *MessageList) GetText() []string

func (*MessageList) GetUuid added in v0.0.3 

func (m *MessageList) GetUuid() string

func (*MessageList) ProtoMessage 

func (*MessageList) ProtoMessage()

func (*MessageList) Reset 

func (m *MessageList) Reset()

func (*MessageList) String 

func (m *MessageList) String() string

func (*MessageList) XXX_DiscardUnknown 

func (m *MessageList) XXX_DiscardUnknown()

func (*MessageList) XXX_Marshal 

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

func (*MessageList) XXX_Merge 

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

func (*MessageList) XXX_Size 

func (m *MessageList) XXX_Size() int

func (*MessageList) XXX_Unmarshal 

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

type MessageReply 

type MessageReply struct {
	Id                   int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Uuid                 string   `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Text                 string   `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageReply) Descriptor 

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

func (*MessageReply) GetId 

func (m *MessageReply) GetId() int64

func (*MessageReply) GetText 

func (m *MessageReply) GetText() string

func (*MessageReply) GetUuid 

func (m *MessageReply) GetUuid() string

func (*MessageReply) ProtoMessage 

func (*MessageReply) ProtoMessage()

func (*MessageReply) Reset 

func (m *MessageReply) Reset()

func (*MessageReply) String 

func (m *MessageReply) String() string

func (*MessageReply) XXX_DiscardUnknown 

func (m *MessageReply) XXX_DiscardUnknown()

func (*MessageReply) XXX_Marshal 

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

func (*MessageReply) XXX_Merge 

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

func (*MessageReply) XXX_Size 

func (m *MessageReply) XXX_Size() int

func (*MessageReply) XXX_Unmarshal 

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

type MessageRequest 

type MessageRequest struct {
	Id                   int64    `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Uuid                 string   `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Text                 string   `protobuf:"bytes,3,opt,name=text,proto3" json:"text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageRequest) Descriptor 

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

func (*MessageRequest) GetId 

func (m *MessageRequest) GetId() int64

func (*MessageRequest) GetText 

func (m *MessageRequest) GetText() string

func (*MessageRequest) GetUuid 

func (m *MessageRequest) GetUuid() string

func (*MessageRequest) ProtoMessage 

func (*MessageRequest) ProtoMessage()

func (*MessageRequest) Reset 

func (m *MessageRequest) Reset()

func (*MessageRequest) String 

func (m *MessageRequest) String() string

func (*MessageRequest) XXX_DiscardUnknown 

func (m *MessageRequest) XXX_DiscardUnknown()

func (*MessageRequest) XXX_Marshal 

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

func (*MessageRequest) XXX_Merge 

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

func (*MessageRequest) XXX_Size 

func (m *MessageRequest) XXX_Size() int

func (*MessageRequest) XXX_Unmarshal 

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

type MessageServer 

type MessageServer interface {
	List(context.Context, *MessageRequest) (*MessageList, error)
	Get(context.Context, *MessageRequest) (*MessageReply, error)
	Create(context.Context, *MessageRequest) (*MessageList, error)
	Delete(context.Context, *MessageRequest) (*MessageReply, error)
	Send(context.Context, *MessageRequest) (*MessageReply, error)
	Run(context.Context, *MessageRequest) (*MessageReply, error)
}

MessageServer is the server API for Message service.

type MiddleClient 

type MiddleClient interface {
	CreatePage(ctx context.Context, in *PageRequest, opts ...grpc.CallOption) (*Text, error)
	GetPage(ctx context.Context, in *PageRequest, opts ...grpc.CallOption) (*PageReply, error)
	Qr(ctx context.Context, in *Text, opts ...grpc.CallOption) (*Text, error)
}

MiddleClient is the client API for Middle service.

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

func NewMiddleClient 

func NewMiddleClient(cc *grpc.ClientConn) MiddleClient

type MiddleServer 

type MiddleServer interface {
	CreatePage(context.Context, *PageRequest) (*Text, error)
	GetPage(context.Context, *PageRequest) (*PageReply, error)
	Qr(context.Context, *Text) (*Text, error)
}

MiddleServer is the server API for Middle service.

type PageReply 

type PageReply struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Title                string   `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Content              string   `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PageReply) Descriptor 

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

func (*PageReply) GetContent 

func (m *PageReply) GetContent() string

func (*PageReply) GetTitle 

func (m *PageReply) GetTitle() string

func (*PageReply) GetUuid 

func (m *PageReply) GetUuid() string

func (*PageReply) ProtoMessage 

func (*PageReply) ProtoMessage()

func (*PageReply) Reset 

func (m *PageReply) Reset()

func (*PageReply) String 

func (m *PageReply) String() string

func (*PageReply) XXX_DiscardUnknown 

func (m *PageReply) XXX_DiscardUnknown()

func (*PageReply) XXX_Marshal 

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

func (*PageReply) XXX_Merge 

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

func (*PageReply) XXX_Size 

func (m *PageReply) XXX_Size() int

func (*PageReply) XXX_Unmarshal 

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

type PageRequest 

type PageRequest struct {
	Uuid                 string   `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Title                string   `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Content              string   `protobuf:"bytes,3,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PageRequest) Descriptor 

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

func (*PageRequest) GetContent 

func (m *PageRequest) GetContent() string

func (*PageRequest) GetTitle 

func (m *PageRequest) GetTitle() string

func (*PageRequest) GetUuid 

func (m *PageRequest) GetUuid() string

func (*PageRequest) ProtoMessage 

func (*PageRequest) ProtoMessage()

func (*PageRequest) Reset 

func (m *PageRequest) Reset()

func (*PageRequest) String 

func (m *PageRequest) String() string

func (*PageRequest) XXX_DiscardUnknown 

func (m *PageRequest) XXX_DiscardUnknown()

func (*PageRequest) XXX_Marshal 

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

func (*PageRequest) XXX_Merge 

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

func (*PageRequest) XXX_Size 

func (m *PageRequest) XXX_Size() int

func (*PageRequest) XXX_Unmarshal 

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

type State 

type State struct {
	State                bool     `protobuf:"varint,1,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*State) Descriptor 

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

func (*State) GetState 

func (m *State) GetState() bool

func (*State) ProtoMessage 

func (*State) ProtoMessage()

func (*State) Reset 

func (m *State) Reset()

func (*State) String 

func (m *State) String() string

func (*State) XXX_DiscardUnknown 

func (m *State) XXX_DiscardUnknown()

func (*State) XXX_Marshal 

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

func (*State) XXX_Merge 

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

func (*State) XXX_Size 

func (m *State) XXX_Size() int

func (*State) XXX_Unmarshal 

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

type SubscribeClient 

type SubscribeClient interface {
	List(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeReply, error)
	Register(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*State, error)
	Open(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*State, error)
	Close(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*State, error)
	Status(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*State, error)
}

SubscribeClient is the client API for Subscribe service.

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

func NewSubscribeClient 

func NewSubscribeClient(cc *grpc.ClientConn) SubscribeClient

type SubscribeReply 

type SubscribeReply struct {
	Text                 []string `protobuf:"bytes,1,rep,name=text,proto3" json:"text,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeReply) Descriptor 

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

func (*SubscribeReply) GetText 

func (m *SubscribeReply) GetText() []string

func (*SubscribeReply) ProtoMessage 

func (*SubscribeReply) ProtoMessage()

func (*SubscribeReply) Reset 

func (m *SubscribeReply) Reset()

func (*SubscribeReply) String 

func (m *SubscribeReply) String() string

func (*SubscribeReply) XXX_DiscardUnknown 

func (m *SubscribeReply) XXX_DiscardUnknown()

func (*SubscribeReply) XXX_Marshal 

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

func (*SubscribeReply) XXX_Merge 

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

func (*SubscribeReply) XXX_Size 

func (m *SubscribeReply) XXX_Size() int

func (*SubscribeReply) XXX_Unmarshal 

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

type SubscribeRequest 

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

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetText 

func (m *SubscribeRequest) GetText() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type SubscribeServer 

type SubscribeServer interface {
	List(context.Context, *SubscribeRequest) (*SubscribeReply, error)
	Register(context.Context, *SubscribeRequest) (*State, error)
	Open(context.Context, *SubscribeRequest) (*State, error)
	Close(context.Context, *SubscribeRequest) (*State, error)
	Status(context.Context, *SubscribeRequest) (*State, error)
}

SubscribeServer is the server API for Subscribe service.

type Text 

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

func (*Text) Descriptor 

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

func (*Text) GetText 

func (m *Text) GetText() string

func (*Text) ProtoMessage 

func (*Text) ProtoMessage()

func (*Text) Reset 

func (m *Text) Reset()

func (*Text) String 

func (m *Text) String() string

func (*Text) XXX_DiscardUnknown 

func (m *Text) XXX_DiscardUnknown()

func (*Text) XXX_Marshal 

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

func (*Text) XXX_Merge 

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

func (*Text) XXX_Size 

func (m *Text) XXX_Size() int

func (*Text) XXX_Unmarshal 

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

type UnimplementedMessageServer 

type UnimplementedMessageServer struct {
}

UnimplementedMessageServer can be embedded to have forward compatible implementations.

func (*UnimplementedMessageServer) Create 

func (*UnimplementedMessageServer) Create(ctx context.Context, req *MessageRequest) (*MessageList, error)

func (*UnimplementedMessageServer) Delete 

func (*UnimplementedMessageServer) Delete(ctx context.Context, req *MessageRequest) (*MessageReply, error)

func (*UnimplementedMessageServer) Get 

func (*UnimplementedMessageServer) Get(ctx context.Context, req *MessageRequest) (*MessageReply, error)

func (*UnimplementedMessageServer) List 

func (*UnimplementedMessageServer) List(ctx context.Context, req *MessageRequest) (*MessageList, error)

func (*UnimplementedMessageServer) Run 

func (*UnimplementedMessageServer) Run(ctx context.Context, req *MessageRequest) (*MessageReply, error)

func (*UnimplementedMessageServer) Send 

func (*UnimplementedMessageServer) Send(ctx context.Context, req *MessageRequest) (*MessageReply, error)

type UnimplementedMiddleServer 

type UnimplementedMiddleServer struct {
}

UnimplementedMiddleServer can be embedded to have forward compatible implementations.

func (*UnimplementedMiddleServer) CreatePage 

func (*UnimplementedMiddleServer) CreatePage(ctx context.Context, req *PageRequest) (*Text, error)

func (*UnimplementedMiddleServer) GetPage 

func (*UnimplementedMiddleServer) GetPage(ctx context.Context, req *PageRequest) (*PageReply, error)

func (*UnimplementedMiddleServer) Qr 

func (*UnimplementedMiddleServer) Qr(ctx context.Context, req *Text) (*Text, error)

type UnimplementedSubscribeServer 

type UnimplementedSubscribeServer struct {
}

UnimplementedSubscribeServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscribeServer) Close 

func (*UnimplementedSubscribeServer) Close(ctx context.Context, req *SubscribeRequest) (*State, error)

func (*UnimplementedSubscribeServer) List 

func (*UnimplementedSubscribeServer) List(ctx context.Context, req *SubscribeRequest) (*SubscribeReply, error)

func (*UnimplementedSubscribeServer) Open 

func (*UnimplementedSubscribeServer) Open(ctx context.Context, req *SubscribeRequest) (*State, error)

func (*UnimplementedSubscribeServer) Register 

func (*UnimplementedSubscribeServer) Register(ctx context.Context, req *SubscribeRequest) (*State, error)

func (*UnimplementedSubscribeServer) Status added in v0.0.4 

func (*UnimplementedSubscribeServer) Status(ctx context.Context, req *SubscribeRequest) (*State, 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.