pb

package
v0.0.13 Latest Latest
Warning

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

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

func RegisterWorkflowServer added in v0.0.9 

func RegisterWorkflowServer(s *grpc.Server, srv WorkflowServer)

Types

type App added in v0.0.9 

type App struct {
	Title                string   `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	IsAuthorized         bool     `protobuf:"varint,2,opt,name=isAuthorized,proto3" json:"isAuthorized,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*App) Descriptor added in v0.0.9 

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

func (*App) GetIsAuthorized added in v0.0.9 

func (m *App) GetIsAuthorized() bool

func (*App) GetTitle added in v0.0.9 

func (m *App) GetTitle() string

func (*App) ProtoMessage added in v0.0.9 

func (*App) ProtoMessage()

func (*App) Reset added in v0.0.9 

func (m *App) Reset()

func (*App) String added in v0.0.9 

func (m *App) String() string

func (*App) XXX_DiscardUnknown added in v0.0.9 

func (m *App) XXX_DiscardUnknown()

func (*App) XXX_Marshal added in v0.0.9 

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

func (*App) XXX_Merge added in v0.0.9 

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

func (*App) XXX_Size added in v0.0.9 

func (m *App) XXX_Size() int

func (*App) XXX_Unmarshal added in v0.0.9 

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

type AppReply added in v0.0.9 

type AppReply struct {
	Apps                 []*App   `protobuf:"bytes,1,rep,name=apps,proto3" json:"apps,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AppReply) Descriptor added in v0.0.9 

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

func (*AppReply) GetApps added in v0.0.9 

func (m *AppReply) GetApps() []*App

func (*AppReply) ProtoMessage added in v0.0.9 

func (*AppReply) ProtoMessage()

func (*AppReply) Reset added in v0.0.9 

func (m *AppReply) Reset()

func (*AppReply) String added in v0.0.9 

func (m *AppReply) String() string

func (*AppReply) XXX_DiscardUnknown added in v0.0.9 

func (m *AppReply) XXX_DiscardUnknown()

func (*AppReply) XXX_Marshal added in v0.0.9 

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

func (*AppReply) XXX_Merge added in v0.0.9 

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

func (*AppReply) XXX_Size added in v0.0.9 

func (m *AppReply) XXX_Size() int

func (*AppReply) XXX_Unmarshal added in v0.0.9 

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

type AppRequest added in v0.0.9 

type AppRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Token                string   `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	Extra                string   `protobuf:"bytes,4,opt,name=extra,proto3" json:"extra,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AppRequest) Descriptor added in v0.0.9 

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

func (*AppRequest) GetExtra added in v0.0.9 

func (m *AppRequest) GetExtra() string

func (*AppRequest) GetName added in v0.0.9 

func (m *AppRequest) GetName() string

func (*AppRequest) GetToken added in v0.0.9 

func (m *AppRequest) GetToken() string

func (*AppRequest) GetType added in v0.0.9 

func (m *AppRequest) GetType() string

func (*AppRequest) ProtoMessage added in v0.0.9 

func (*AppRequest) ProtoMessage()

func (*AppRequest) Reset added in v0.0.9 

func (m *AppRequest) Reset()

func (*AppRequest) String added in v0.0.9 

func (m *AppRequest) String() string

func (*AppRequest) XXX_DiscardUnknown added in v0.0.9 

func (m *AppRequest) XXX_DiscardUnknown()

func (*AppRequest) XXX_Marshal added in v0.0.9 

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

func (*AppRequest) XXX_Merge added in v0.0.9 

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

func (*AppRequest) XXX_Size added in v0.0.9 

func (m *AppRequest) XXX_Size() int

func (*AppRequest) XXX_Unmarshal added in v0.0.9 

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

type CredentialReply added in v0.0.9 

type CredentialReply struct {
	Items                []*KV    `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CredentialReply) Descriptor added in v0.0.9 

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

func (*CredentialReply) GetItems added in v0.0.9 

func (m *CredentialReply) GetItems() []*KV

func (*CredentialReply) ProtoMessage added in v0.0.9 

func (*CredentialReply) ProtoMessage()

func (*CredentialReply) Reset added in v0.0.9 

func (m *CredentialReply) Reset()

func (*CredentialReply) String added in v0.0.9 

func (m *CredentialReply) String() string

func (*CredentialReply) XXX_DiscardUnknown added in v0.0.9 

func (m *CredentialReply) XXX_DiscardUnknown()

func (*CredentialReply) XXX_Marshal added in v0.0.9 

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

func (*CredentialReply) XXX_Merge added in v0.0.9 

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

func (*CredentialReply) XXX_Size added in v0.0.9 

func (m *CredentialReply) XXX_Size() int

func (*CredentialReply) XXX_Unmarshal added in v0.0.9 

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

type KV added in v0.0.9 

type KV struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KV) Descriptor added in v0.0.9 

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

func (*KV) GetKey added in v0.0.9 

func (m *KV) GetKey() string

func (*KV) GetValue added in v0.0.9 

func (m *KV) GetValue() string

func (*KV) ProtoMessage added in v0.0.9 

func (*KV) ProtoMessage()

func (*KV) Reset added in v0.0.9 

func (m *KV) Reset()

func (*KV) String added in v0.0.9 

func (m *KV) String() string

func (*KV) XXX_DiscardUnknown added in v0.0.9 

func (m *KV) XXX_DiscardUnknown()

func (*KV) XXX_Marshal added in v0.0.9 

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

func (*KV) XXX_Merge added in v0.0.9 

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

func (*KV) XXX_Size added in v0.0.9 

func (m *KV) XXX_Size() int

func (*KV) XXX_Unmarshal added in v0.0.9 

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

type KVRequest added in v0.0.9 

type KVRequest struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KVRequest) Descriptor added in v0.0.9 

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

func (*KVRequest) GetKey added in v0.0.9 

func (m *KVRequest) GetKey() string

func (*KVRequest) GetValue added in v0.0.9 

func (m *KVRequest) GetValue() string

func (*KVRequest) ProtoMessage added in v0.0.9 

func (*KVRequest) ProtoMessage()

func (*KVRequest) Reset added in v0.0.9 

func (m *KVRequest) Reset()

func (*KVRequest) String added in v0.0.9 

func (m *KVRequest) String() string

func (*KVRequest) XXX_DiscardUnknown added in v0.0.9 

func (m *KVRequest) XXX_DiscardUnknown()

func (*KVRequest) XXX_Marshal added in v0.0.9 

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

func (*KVRequest) XXX_Merge added in v0.0.9 

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

func (*KVRequest) XXX_Size added in v0.0.9 

func (m *KVRequest) XXX_Size() int

func (*KVRequest) XXX_Unmarshal added in v0.0.9 

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

type KVsRequest added in v0.0.9 

type KVsRequest struct {
	Kvs                  []*KV    `protobuf:"bytes,1,rep,name=kvs,proto3" json:"kvs,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KVsRequest) Descriptor added in v0.0.9 

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

func (*KVsRequest) GetKvs added in v0.0.9 

func (m *KVsRequest) GetKvs() []*KV

func (*KVsRequest) ProtoMessage added in v0.0.9 

func (*KVsRequest) ProtoMessage()

func (*KVsRequest) Reset added in v0.0.9 

func (m *KVsRequest) Reset()

func (*KVsRequest) String added in v0.0.9 

func (m *KVsRequest) String() string

func (*KVsRequest) XXX_DiscardUnknown added in v0.0.9 

func (m *KVsRequest) XXX_DiscardUnknown()

func (*KVsRequest) XXX_Marshal added in v0.0.9 

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

func (*KVsRequest) XXX_Merge added in v0.0.9 

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

func (*KVsRequest) XXX_Size added in v0.0.9 

func (m *KVsRequest) XXX_Size() int

func (*KVsRequest) XXX_Unmarshal added in v0.0.9 

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

type MessageClient 

type MessageClient interface {
	List(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageListReply, error)
	Get(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*TextReply, error)
	Create(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*MessageReply, error)
	Delete(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*TextReply, error)
	Send(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*TextReply, error)
	Run(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*TextReply, 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 MessageItem added in v0.0.9 

type MessageItem 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"`
	Type                 string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	Time                 string   `protobuf:"bytes,5,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MessageItem) Descriptor added in v0.0.9 

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

func (*MessageItem) GetId added in v0.0.9 

func (m *MessageItem) GetId() int64

func (*MessageItem) GetText added in v0.0.9 

func (m *MessageItem) GetText() string

func (*MessageItem) GetTime added in v0.0.9 

func (m *MessageItem) GetTime() string

func (*MessageItem) GetType added in v0.0.9 

func (m *MessageItem) GetType() string

func (*MessageItem) GetUuid added in v0.0.9 

func (m *MessageItem) GetUuid() string

func (*MessageItem) ProtoMessage added in v0.0.9 

func (*MessageItem) ProtoMessage()

func (*MessageItem) Reset added in v0.0.9 

func (m *MessageItem) Reset()

func (*MessageItem) String added in v0.0.9 

func (m *MessageItem) String() string

func (*MessageItem) XXX_DiscardUnknown added in v0.0.9 

func (m *MessageItem) XXX_DiscardUnknown()

func (*MessageItem) XXX_Marshal added in v0.0.9 

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

func (*MessageItem) XXX_Merge added in v0.0.9 

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

func (*MessageItem) XXX_Size added in v0.0.9 

func (m *MessageItem) XXX_Size() int

func (*MessageItem) XXX_Unmarshal added in v0.0.9 

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

type MessageListReply added in v0.0.9 

type MessageListReply struct {
	Messages             []*MessageItem `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*MessageListReply) Descriptor added in v0.0.9 

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

func (*MessageListReply) GetMessages added in v0.0.9 

func (m *MessageListReply) GetMessages() []*MessageItem

func (*MessageListReply) ProtoMessage added in v0.0.9 

func (*MessageListReply) ProtoMessage()

func (*MessageListReply) Reset added in v0.0.9 

func (m *MessageListReply) Reset()

func (*MessageListReply) String added in v0.0.9 

func (m *MessageListReply) String() string

func (*MessageListReply) XXX_DiscardUnknown added in v0.0.9 

func (m *MessageListReply) XXX_DiscardUnknown()

func (*MessageListReply) XXX_Marshal added in v0.0.9 

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

func (*MessageListReply) XXX_Merge added in v0.0.9 

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

func (*MessageListReply) XXX_Size added in v0.0.9 

func (m *MessageListReply) XXX_Size() int

func (*MessageListReply) XXX_Unmarshal added in v0.0.9 

func (m *MessageListReply) 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,rep,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) (*MessageListReply, error)
	Get(context.Context, *MessageRequest) (*TextReply, error)
	Create(context.Context, *MessageRequest) (*MessageReply, error)
	Delete(context.Context, *MessageRequest) (*TextReply, error)
	Send(context.Context, *MessageRequest) (*TextReply, error)
	Run(context.Context, *MessageRequest) (*TextReply, error)
}

MessageServer is the server API for Message service.

type MiddleClient 

type MiddleClient interface {
	CreatePage(ctx context.Context, in *PageRequest, opts ...grpc.CallOption) (*TextReply, error)
	GetPage(ctx context.Context, in *PageRequest, opts ...grpc.CallOption) (*PageReply, error)
	Qr(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*TextReply, error)
	Apps(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*AppReply, error)
	StoreAppOAuth(ctx context.Context, in *AppRequest, opts ...grpc.CallOption) (*StateReply, error)
	GetCredentials(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*CredentialReply, error)
	CreateCredential(ctx context.Context, in *KVsRequest, opts ...grpc.CallOption) (*TextReply, error)
	GetSetting(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*SettingReply, error)
	CreateSetting(ctx context.Context, in *KVRequest, opts ...grpc.CallOption) (*TextReply, error)
	GetMenu(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*TextReply, error)
	Authorization(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*StateReply, 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) (*TextReply, error)
	GetPage(context.Context, *PageRequest) (*PageReply, error)
	Qr(context.Context, *TextRequest) (*TextReply, error)
	Apps(context.Context, *TextRequest) (*AppReply, error)
	StoreAppOAuth(context.Context, *AppRequest) (*StateReply, error)
	GetCredentials(context.Context, *TextRequest) (*CredentialReply, error)
	CreateCredential(context.Context, *KVsRequest) (*TextReply, error)
	GetSetting(context.Context, *TextRequest) (*SettingReply, error)
	CreateSetting(context.Context, *KVRequest) (*TextReply, error)
	GetMenu(context.Context, *TextRequest) (*TextReply, error)
	Authorization(context.Context, *TextRequest) (*StateReply, 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 SettingReply added in v0.0.9 

type SettingReply struct {
	Items                []*KV    `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SettingReply) Descriptor added in v0.0.9 

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

func (*SettingReply) GetItems added in v0.0.9 

func (m *SettingReply) GetItems() []*KV

func (*SettingReply) ProtoMessage added in v0.0.9 

func (*SettingReply) ProtoMessage()

func (*SettingReply) Reset added in v0.0.9 

func (m *SettingReply) Reset()

func (*SettingReply) String added in v0.0.9 

func (m *SettingReply) String() string

func (*SettingReply) XXX_DiscardUnknown added in v0.0.9 

func (m *SettingReply) XXX_DiscardUnknown()

func (*SettingReply) XXX_Marshal added in v0.0.9 

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

func (*SettingReply) XXX_Merge added in v0.0.9 

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

func (*SettingReply) XXX_Size added in v0.0.9 

func (m *SettingReply) XXX_Size() int

func (*SettingReply) XXX_Unmarshal added in v0.0.9 

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

type StateReply added in v0.0.9 

type StateReply 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 (*StateReply) Descriptor added in v0.0.9 

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

func (*StateReply) GetState added in v0.0.9 

func (m *StateReply) GetState() bool

func (*StateReply) ProtoMessage added in v0.0.9 

func (*StateReply) ProtoMessage()

func (*StateReply) Reset added in v0.0.9 

func (m *StateReply) Reset()

func (*StateReply) String added in v0.0.9 

func (m *StateReply) String() string

func (*StateReply) XXX_DiscardUnknown added in v0.0.9 

func (m *StateReply) XXX_DiscardUnknown()

func (*StateReply) XXX_Marshal added in v0.0.9 

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

func (*StateReply) XXX_Merge added in v0.0.9 

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

func (*StateReply) XXX_Size added in v0.0.9 

func (m *StateReply) XXX_Size() int

func (*StateReply) XXX_Unmarshal added in v0.0.9 

func (m *StateReply) 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) (*StateReply, error)
	Open(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*StateReply, error)
	Close(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*StateReply, error)
	Status(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*StateReply, 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) (*StateReply, error)
	Open(context.Context, *SubscribeRequest) (*StateReply, error)
	Close(context.Context, *SubscribeRequest) (*StateReply, error)
	Status(context.Context, *SubscribeRequest) (*StateReply, error)
}

SubscribeServer is the server API for Subscribe service.

type TextReply added in v0.0.9 

type TextReply 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 (*TextReply) Descriptor added in v0.0.9 

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

func (*TextReply) GetText added in v0.0.9 

func (m *TextReply) GetText() string

func (*TextReply) ProtoMessage added in v0.0.9 

func (*TextReply) ProtoMessage()

func (*TextReply) Reset added in v0.0.9 

func (m *TextReply) Reset()

func (*TextReply) String added in v0.0.9 

func (m *TextReply) String() string

func (*TextReply) XXX_DiscardUnknown added in v0.0.9 

func (m *TextReply) XXX_DiscardUnknown()

func (*TextReply) XXX_Marshal added in v0.0.9 

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

func (*TextReply) XXX_Merge added in v0.0.9 

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

func (*TextReply) XXX_Size added in v0.0.9 

func (m *TextReply) XXX_Size() int

func (*TextReply) XXX_Unmarshal added in v0.0.9 

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

type TextRequest added in v0.0.9 

type TextRequest 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 (*TextRequest) Descriptor added in v0.0.9 

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

func (*TextRequest) GetText added in v0.0.9 

func (m *TextRequest) GetText() string

func (*TextRequest) ProtoMessage added in v0.0.9 

func (*TextRequest) ProtoMessage()

func (*TextRequest) Reset added in v0.0.9 

func (m *TextRequest) Reset()

func (*TextRequest) String added in v0.0.9 

func (m *TextRequest) String() string

func (*TextRequest) XXX_DiscardUnknown added in v0.0.9 

func (m *TextRequest) XXX_DiscardUnknown()

func (*TextRequest) XXX_Marshal added in v0.0.9 

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

func (*TextRequest) XXX_Merge added in v0.0.9 

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

func (*TextRequest) XXX_Size added in v0.0.9 

func (m *TextRequest) XXX_Size() int

func (*TextRequest) XXX_Unmarshal added in v0.0.9 

func (m *TextRequest) 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) (*MessageReply, error)

func (*UnimplementedMessageServer) Delete 

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

func (*UnimplementedMessageServer) Get 

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

func (*UnimplementedMessageServer) List 

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

func (*UnimplementedMessageServer) Run 

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

func (*UnimplementedMessageServer) Send 

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

type UnimplementedMiddleServer 

type UnimplementedMiddleServer struct {
}

UnimplementedMiddleServer can be embedded to have forward compatible implementations.

func (*UnimplementedMiddleServer) Apps added in v0.0.9 

func (*UnimplementedMiddleServer) Apps(ctx context.Context, req *TextRequest) (*AppReply, error)

func (*UnimplementedMiddleServer) Authorization added in v0.0.9 

func (*UnimplementedMiddleServer) Authorization(ctx context.Context, req *TextRequest) (*StateReply, error)

func (*UnimplementedMiddleServer) CreateCredential added in v0.0.9 

func (*UnimplementedMiddleServer) CreateCredential(ctx context.Context, req *KVsRequest) (*TextReply, error)

func (*UnimplementedMiddleServer) CreatePage 

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

func (*UnimplementedMiddleServer) CreateSetting added in v0.0.9 

func (*UnimplementedMiddleServer) CreateSetting(ctx context.Context, req *KVRequest) (*TextReply, error)

func (*UnimplementedMiddleServer) GetCredentials added in v0.0.9 

func (*UnimplementedMiddleServer) GetCredentials(ctx context.Context, req *TextRequest) (*CredentialReply, error)

func (*UnimplementedMiddleServer) GetMenu added in v0.0.9 

func (*UnimplementedMiddleServer) GetMenu(ctx context.Context, req *TextRequest) (*TextReply, error)

func (*UnimplementedMiddleServer) GetPage 

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

func (*UnimplementedMiddleServer) GetSetting added in v0.0.9 

func (*UnimplementedMiddleServer) GetSetting(ctx context.Context, req *TextRequest) (*SettingReply, error)

func (*UnimplementedMiddleServer) Qr 

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

func (*UnimplementedMiddleServer) StoreAppOAuth added in v0.0.9 

func (*UnimplementedMiddleServer) StoreAppOAuth(ctx context.Context, req *AppRequest) (*StateReply, 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) (*StateReply, 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) (*StateReply, error)

func (*UnimplementedSubscribeServer) Register 

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

func (*UnimplementedSubscribeServer) Status added in v0.0.4 

func (*UnimplementedSubscribeServer) Status(ctx context.Context, req *SubscribeRequest) (*StateReply, error)

type UnimplementedWorkflowServer added in v0.0.9 

type UnimplementedWorkflowServer struct {
}

UnimplementedWorkflowServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowServer) Run added in v0.0.9 

func (*UnimplementedWorkflowServer) Run(ctx context.Context, req *WorkflowRequest) (*WorkflowReply, error)

type WorkflowClient added in v0.0.9 

type WorkflowClient interface {
	Run(ctx context.Context, in *WorkflowRequest, opts ...grpc.CallOption) (*WorkflowReply, error)
}

WorkflowClient is the client API for Workflow service.

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

func NewWorkflowClient added in v0.0.9 

func NewWorkflowClient(cc *grpc.ClientConn) WorkflowClient

type WorkflowReply added in v0.0.9 

type WorkflowReply 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 (*WorkflowReply) Descriptor added in v0.0.9 

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

func (*WorkflowReply) GetText added in v0.0.9 

func (m *WorkflowReply) GetText() string

func (*WorkflowReply) ProtoMessage added in v0.0.9 

func (*WorkflowReply) ProtoMessage()

func (*WorkflowReply) Reset added in v0.0.9 

func (m *WorkflowReply) Reset()

func (*WorkflowReply) String added in v0.0.9 

func (m *WorkflowReply) String() string

func (*WorkflowReply) XXX_DiscardUnknown added in v0.0.9 

func (m *WorkflowReply) XXX_DiscardUnknown()

func (*WorkflowReply) XXX_Marshal added in v0.0.9 

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

func (*WorkflowReply) XXX_Merge added in v0.0.9 

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

func (*WorkflowReply) XXX_Size added in v0.0.9 

func (m *WorkflowReply) XXX_Size() int

func (*WorkflowReply) XXX_Unmarshal added in v0.0.9 

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

type WorkflowRequest added in v0.0.9 

type WorkflowRequest 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 (*WorkflowRequest) Descriptor added in v0.0.9 

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

func (*WorkflowRequest) GetText added in v0.0.9 

func (m *WorkflowRequest) GetText() string

func (*WorkflowRequest) ProtoMessage added in v0.0.9 

func (*WorkflowRequest) ProtoMessage()

func (*WorkflowRequest) Reset added in v0.0.9 

func (m *WorkflowRequest) Reset()

func (*WorkflowRequest) String added in v0.0.9 

func (m *WorkflowRequest) String() string

func (*WorkflowRequest) XXX_DiscardUnknown added in v0.0.9 

func (m *WorkflowRequest) XXX_DiscardUnknown()

func (*WorkflowRequest) XXX_Marshal added in v0.0.9 

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

func (*WorkflowRequest) XXX_Merge added in v0.0.9 

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

func (*WorkflowRequest) XXX_Size added in v0.0.9 

func (m *WorkflowRequest) XXX_Size() int

func (*WorkflowRequest) XXX_Unmarshal added in v0.0.9 

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

type WorkflowServer added in v0.0.9 

type WorkflowServer interface {
	Run(context.Context, *WorkflowRequest) (*WorkflowReply, error)
}

WorkflowServer is the server API for Workflow service.

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.