pb

package
v0.0.22 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 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 RegisterStorageServer added in v0.0.22 

func RegisterStorageServer(s *grpc.Server, srv StorageServer)

func RegisterSubscribeServer 

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

func RegisterTaskServer added in v0.0.17 

func RegisterTaskServer(s *grpc.Server, srv TaskServer)

func RegisterWorkflowServer added in v0.0.9 

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

Types

type Action added in v0.0.16 

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

func (*Action) Descriptor added in v0.0.16 

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

func (*Action) GetId added in v0.0.16 

func (m *Action) GetId() int64

func (*Action) GetText added in v0.0.16 

func (m *Action) GetText() string

func (*Action) ProtoMessage added in v0.0.16 

func (*Action) ProtoMessage()

func (*Action) Reset added in v0.0.16 

func (m *Action) Reset()

func (*Action) String added in v0.0.16 

func (m *Action) String() string

func (*Action) XXX_DiscardUnknown added in v0.0.16 

func (m *Action) XXX_DiscardUnknown()

func (*Action) XXX_Marshal added in v0.0.16 

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

func (*Action) XXX_Merge added in v0.0.16 

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

func (*Action) XXX_Size added in v0.0.16 

func (m *Action) XXX_Size() int

func (*Action) XXX_Unmarshal added in v0.0.16 

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

type ActionReply added in v0.0.16 

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

func (*ActionReply) Descriptor added in v0.0.16 

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

func (*ActionReply) GetItems added in v0.0.16 

func (m *ActionReply) GetItems() []*Action

func (*ActionReply) ProtoMessage added in v0.0.16 

func (*ActionReply) ProtoMessage()

func (*ActionReply) Reset added in v0.0.16 

func (m *ActionReply) Reset()

func (*ActionReply) String added in v0.0.16 

func (m *ActionReply) String() string

func (*ActionReply) XXX_DiscardUnknown added in v0.0.16 

func (m *ActionReply) XXX_DiscardUnknown()

func (*ActionReply) XXX_Marshal added in v0.0.16 

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

func (*ActionReply) XXX_Merge added in v0.0.16 

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

func (*ActionReply) XXX_Size added in v0.0.16 

func (m *ActionReply) XXX_Size() int

func (*ActionReply) XXX_Unmarshal added in v0.0.16 

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

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"`
	Type                 string   `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	Name                 string   `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Token                string   `protobuf:"bytes,5,opt,name=token,proto3" json:"token,omitempty"`
	Extra                string   `protobuf:"bytes,6,opt,name=extra,proto3" json:"extra,omitempty"`
	Time                 string   `protobuf:"bytes,7,opt,name=time,proto3" json:"time,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) GetExtra added in v0.0.17 

func (m *App) GetExtra() string

func (*App) GetIsAuthorized added in v0.0.9 

func (m *App) GetIsAuthorized() bool

func (*App) GetName added in v0.0.17 

func (m *App) GetName() string

func (*App) GetTime added in v0.0.17 

func (m *App) GetTime() string

func (*App) GetTitle added in v0.0.9 

func (m *App) GetTitle() string

func (*App) GetToken added in v0.0.17 

func (m *App) GetToken() string

func (*App) GetType added in v0.0.15 

func (m *App) GetType() 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 {
	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                []*KV    `protobuf:"bytes,4,rep,name=extra,proto3" json:"extra,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) GetExtra added in v0.0.15 

func (m *AppReply) GetExtra() []*KV

func (*AppReply) GetName added in v0.0.15 

func (m *AppReply) GetName() string

func (*AppReply) GetToken added in v0.0.15 

func (m *AppReply) GetToken() string

func (*AppReply) GetType added in v0.0.15 

func (m *AppReply) GetType() string

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 AppsReply added in v0.0.15 

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

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

func (*AppsReply) GetApps added in v0.0.15 

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

func (*AppsReply) ProtoMessage added in v0.0.15 

func (*AppsReply) ProtoMessage()

func (*AppsReply) Reset added in v0.0.15 

func (m *AppsReply) Reset()

func (*AppsReply) String added in v0.0.15 

func (m *AppsReply) String() string

func (*AppsReply) XXX_DiscardUnknown added in v0.0.15 

func (m *AppsReply) XXX_DiscardUnknown()

func (*AppsReply) XXX_Marshal added in v0.0.15 

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

func (*AppsReply) XXX_Merge added in v0.0.15 

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

func (*AppsReply) XXX_Size added in v0.0.15 

func (m *AppsReply) XXX_Size() int

func (*AppsReply) XXX_Unmarshal added in v0.0.15 

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

type Credential added in v0.0.17 

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

func (*Credential) Descriptor added in v0.0.17 

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

func (*Credential) GetContent added in v0.0.17 

func (m *Credential) GetContent() string

func (*Credential) GetName added in v0.0.17 

func (m *Credential) GetName() string

func (*Credential) GetTime added in v0.0.17 

func (m *Credential) GetTime() string

func (*Credential) GetType added in v0.0.17 

func (m *Credential) GetType() string

func (*Credential) ProtoMessage added in v0.0.17 

func (*Credential) ProtoMessage()

func (*Credential) Reset added in v0.0.17 

func (m *Credential) Reset()

func (*Credential) String added in v0.0.17 

func (m *Credential) String() string

func (*Credential) XXX_DiscardUnknown added in v0.0.17 

func (m *Credential) XXX_DiscardUnknown()

func (*Credential) XXX_Marshal added in v0.0.17 

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

func (*Credential) XXX_Merge added in v0.0.17 

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

func (*Credential) XXX_Size added in v0.0.17 

func (m *Credential) XXX_Size() int

func (*Credential) XXX_Unmarshal added in v0.0.17 

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

type CredentialReply added in v0.0.9 

type CredentialReply 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"`
	Content              []*KV    `protobuf:"bytes,3,rep,name=content,proto3" json:"content,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) GetContent added in v0.0.15 

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

func (*CredentialReply) GetName added in v0.0.15 

func (m *CredentialReply) GetName() string

func (*CredentialReply) GetType added in v0.0.15 

func (m *CredentialReply) GetType() string

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 CredentialRequest added in v0.0.15 

type CredentialRequest 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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CredentialRequest) Descriptor added in v0.0.15 

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

func (*CredentialRequest) GetName added in v0.0.15 

func (m *CredentialRequest) GetName() string

func (*CredentialRequest) GetType added in v0.0.15 

func (m *CredentialRequest) GetType() string

func (*CredentialRequest) ProtoMessage added in v0.0.15 

func (*CredentialRequest) ProtoMessage()

func (*CredentialRequest) Reset added in v0.0.15 

func (m *CredentialRequest) Reset()

func (*CredentialRequest) String added in v0.0.15 

func (m *CredentialRequest) String() string

func (*CredentialRequest) XXX_DiscardUnknown added in v0.0.15 

func (m *CredentialRequest) XXX_DiscardUnknown()

func (*CredentialRequest) XXX_Marshal added in v0.0.15 

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

func (*CredentialRequest) XXX_Merge added in v0.0.15 

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

func (*CredentialRequest) XXX_Size added in v0.0.15 

func (m *CredentialRequest) XXX_Size() int

func (*CredentialRequest) XXX_Unmarshal added in v0.0.15 

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

type CredentialsReply added in v0.0.15 

type CredentialsReply struct {
	Credentials          []*Credential `protobuf:"bytes,1,rep,name=credentials,proto3" json:"credentials,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*CredentialsReply) Descriptor added in v0.0.15 

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

func (*CredentialsReply) GetCredentials added in v0.0.17 

func (m *CredentialsReply) GetCredentials() []*Credential

func (*CredentialsReply) ProtoMessage added in v0.0.15 

func (*CredentialsReply) ProtoMessage()

func (*CredentialsReply) Reset added in v0.0.15 

func (m *CredentialsReply) Reset()

func (*CredentialsReply) String added in v0.0.15 

func (m *CredentialsReply) String() string

func (*CredentialsReply) XXX_DiscardUnknown added in v0.0.15 

func (m *CredentialsReply) XXX_DiscardUnknown()

func (*CredentialsReply) XXX_Marshal added in v0.0.15 

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

func (*CredentialsReply) XXX_Merge added in v0.0.15 

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

func (*CredentialsReply) XXX_Size added in v0.0.15 

func (m *CredentialsReply) XXX_Size() int

func (*CredentialsReply) XXX_Unmarshal added in v0.0.15 

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

type FileInfo added in v0.0.22 

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

func (*FileInfo) Descriptor added in v0.0.22 

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

func (*FileInfo) GetFileType added in v0.0.22 

func (m *FileInfo) GetFileType() string

func (*FileInfo) ProtoMessage added in v0.0.22 

func (*FileInfo) ProtoMessage()

func (*FileInfo) Reset added in v0.0.22 

func (m *FileInfo) Reset()

func (*FileInfo) String added in v0.0.22 

func (m *FileInfo) String() string

func (*FileInfo) XXX_DiscardUnknown added in v0.0.22 

func (m *FileInfo) XXX_DiscardUnknown()

func (*FileInfo) XXX_Marshal added in v0.0.22 

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

func (*FileInfo) XXX_Merge added in v0.0.22 

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

func (*FileInfo) XXX_Size added in v0.0.22 

func (m *FileInfo) XXX_Size() int

func (*FileInfo) XXX_Unmarshal added in v0.0.22 

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

type FileReply added in v0.0.22 

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

func (*FileReply) Descriptor added in v0.0.22 

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

func (*FileReply) GetPath added in v0.0.22 

func (m *FileReply) GetPath() string

func (*FileReply) ProtoMessage added in v0.0.22 

func (*FileReply) ProtoMessage()

func (*FileReply) Reset added in v0.0.22 

func (m *FileReply) Reset()

func (*FileReply) String added in v0.0.22 

func (m *FileReply) String() string

func (*FileReply) XXX_DiscardUnknown added in v0.0.22 

func (m *FileReply) XXX_DiscardUnknown()

func (*FileReply) XXX_Marshal added in v0.0.22 

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

func (*FileReply) XXX_Merge added in v0.0.22 

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

func (*FileReply) XXX_Size added in v0.0.22 

func (m *FileReply) XXX_Size() int

func (*FileReply) XXX_Unmarshal added in v0.0.22 

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

type FileRequest added in v0.0.22 

type FileRequest struct {
	// Types that are valid to be assigned to Data:
	//	*FileRequest_Info
	//	*FileRequest_Chuck
	Data                 isFileRequest_Data `protobuf_oneof:"data"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*FileRequest) Descriptor added in v0.0.22 

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

func (*FileRequest) GetChuck added in v0.0.22 

func (m *FileRequest) GetChuck() []byte

func (*FileRequest) GetData added in v0.0.22 

func (m *FileRequest) GetData() isFileRequest_Data

func (*FileRequest) GetInfo added in v0.0.22 

func (m *FileRequest) GetInfo() *FileInfo

func (*FileRequest) ProtoMessage added in v0.0.22 

func (*FileRequest) ProtoMessage()

func (*FileRequest) Reset added in v0.0.22 

func (m *FileRequest) Reset()

func (*FileRequest) String added in v0.0.22 

func (m *FileRequest) String() string

func (*FileRequest) XXX_DiscardUnknown added in v0.0.22 

func (m *FileRequest) XXX_DiscardUnknown()

func (*FileRequest) XXX_Marshal added in v0.0.22 

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

func (*FileRequest) XXX_Merge added in v0.0.22 

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

func (*FileRequest) XXX_OneofWrappers added in v0.0.22 

func (*FileRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*FileRequest) XXX_Size added in v0.0.22 

func (m *FileRequest) XXX_Size() int

func (*FileRequest) XXX_Unmarshal added in v0.0.22 

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

type FileRequest_Chuck added in v0.0.22 

type FileRequest_Chuck struct {
	Chuck []byte `protobuf:"bytes,2,opt,name=chuck,proto3,oneof" json:"chuck,omitempty"`
}

type FileRequest_Info added in v0.0.22 

type FileRequest_Info struct {
	Info *FileInfo `protobuf:"bytes,1,opt,name=info,proto3,oneof" json:"info,omitempty"`
}

type JobRequest added in v0.0.17 

type JobRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args                 string   `protobuf:"bytes,2,opt,name=args,proto3" json:"args,omitempty"`
	Time                 string   `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JobRequest) Descriptor added in v0.0.17 

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

func (*JobRequest) GetArgs added in v0.0.18 

func (m *JobRequest) GetArgs() string

func (*JobRequest) GetName added in v0.0.18 

func (m *JobRequest) GetName() string

func (*JobRequest) GetTime added in v0.0.20 

func (m *JobRequest) GetTime() string

func (*JobRequest) ProtoMessage added in v0.0.17 

func (*JobRequest) ProtoMessage()

func (*JobRequest) Reset added in v0.0.17 

func (m *JobRequest) Reset()

func (*JobRequest) String added in v0.0.17 

func (m *JobRequest) String() string

func (*JobRequest) XXX_DiscardUnknown added in v0.0.17 

func (m *JobRequest) XXX_DiscardUnknown()

func (*JobRequest) XXX_Marshal added in v0.0.17 

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

func (*JobRequest) XXX_Merge added in v0.0.17 

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

func (*JobRequest) XXX_Size added in v0.0.17 

func (m *JobRequest) XXX_Size() int

func (*JobRequest) XXX_Unmarshal added in v0.0.17 

func (m *JobRequest) 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 MaskingReply added in v0.0.17 

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

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

func (*MaskingReply) GetItems added in v0.0.17 

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

func (*MaskingReply) ProtoMessage added in v0.0.17 

func (*MaskingReply) ProtoMessage()

func (*MaskingReply) Reset added in v0.0.17 

func (m *MaskingReply) Reset()

func (*MaskingReply) String added in v0.0.17 

func (m *MaskingReply) String() string

func (*MaskingReply) XXX_DiscardUnknown added in v0.0.17 

func (m *MaskingReply) XXX_DiscardUnknown()

func (*MaskingReply) XXX_Marshal added in v0.0.17 

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

func (*MaskingReply) XXX_Merge added in v0.0.17 

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

func (*MaskingReply) XXX_Size added in v0.0.17 

func (m *MaskingReply) XXX_Size() int

func (*MaskingReply) XXX_Unmarshal added in v0.0.17 

func (m *MaskingReply) 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) (*MessageReply, error)
	Create(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*TextsReply, error)
	Delete(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*TextReply, error)
	Send(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*StateReply, error)
	Run(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*TextReply, error)
	GetActionMessages(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*ActionReply, error)
	CreateActionMessage(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*StateReply, error)
	DeleteWorkflowMessage(ctx context.Context, in *MessageRequest, opts ...grpc.CallOption) (*StateReply, 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,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 (*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) GetTime added in v0.0.18 

func (m *MessageReply) GetTime() string

func (*MessageReply) GetType added in v0.0.18 

func (m *MessageReply) GetType() 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) (*MessageReply, error)
	Create(context.Context, *MessageRequest) (*TextsReply, error)
	Delete(context.Context, *MessageRequest) (*TextReply, error)
	Send(context.Context, *MessageRequest) (*StateReply, error)
	Run(context.Context, *MessageRequest) (*TextReply, error)
	GetActionMessages(context.Context, *TextRequest) (*ActionReply, error)
	CreateActionMessage(context.Context, *TextRequest) (*StateReply, error)
	DeleteWorkflowMessage(context.Context, *MessageRequest) (*StateReply, 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)
	GetQrUrl(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*TextReply, error)
	GetApps(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*AppsReply, error)
	GetAvailableApp(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) (*CredentialsReply, error)
	GetMaskingCredentials(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*MaskingReply, error)
	GetCredential(ctx context.Context, in *CredentialRequest, opts ...grpc.CallOption) (*CredentialReply, error)
	CreateCredential(ctx context.Context, in *KVsRequest, opts ...grpc.CallOption) (*StateReply, error)
	GetSettings(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*SettingsReply, error)
	GetSetting(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*SettingReply, error)
	CreateSetting(ctx context.Context, in *KVRequest, opts ...grpc.CallOption) (*StateReply, error)
	GetMenu(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*TextReply, error)
	Authorization(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*StateReply, error)
	GetStats(ctx context.Context, in *TextRequest, opts ...grpc.CallOption) (*TextReply, 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)
	GetQrUrl(context.Context, *TextRequest) (*TextReply, error)
	GetApps(context.Context, *TextRequest) (*AppsReply, error)
	GetAvailableApp(context.Context, *TextRequest) (*AppReply, error)
	StoreAppOAuth(context.Context, *AppRequest) (*StateReply, error)
	GetCredentials(context.Context, *TextRequest) (*CredentialsReply, error)
	GetMaskingCredentials(context.Context, *TextRequest) (*MaskingReply, error)
	GetCredential(context.Context, *CredentialRequest) (*CredentialReply, error)
	CreateCredential(context.Context, *KVsRequest) (*StateReply, error)
	GetSettings(context.Context, *TextRequest) (*SettingsReply, error)
	GetSetting(context.Context, *TextRequest) (*SettingReply, error)
	CreateSetting(context.Context, *KVRequest) (*StateReply, error)
	GetMenu(context.Context, *TextRequest) (*TextReply, error)
	Authorization(context.Context, *TextRequest) (*StateReply, error)
	GetStats(context.Context, *TextRequest) (*TextReply, 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"`
	Type                 string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,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) GetType added in v0.0.20 

func (m *PageReply) GetType() 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"`
	Type                 string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,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) GetType added in v0.0.20 

func (m *PageRequest) GetType() 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 {
	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 (*SettingReply) Descriptor added in v0.0.9 

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

func (*SettingReply) GetKey added in v0.0.21 

func (m *SettingReply) GetKey() string

func (*SettingReply) GetValue added in v0.0.21 

func (m *SettingReply) GetValue() string

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 SettingsReply added in v0.0.21 

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

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

func (*SettingsReply) GetItems added in v0.0.21 

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

func (*SettingsReply) ProtoMessage added in v0.0.21 

func (*SettingsReply) ProtoMessage()

func (*SettingsReply) Reset added in v0.0.21 

func (m *SettingsReply) Reset()

func (*SettingsReply) String added in v0.0.21 

func (m *SettingsReply) String() string

func (*SettingsReply) XXX_DiscardUnknown added in v0.0.21 

func (m *SettingsReply) XXX_DiscardUnknown()

func (*SettingsReply) XXX_Marshal added in v0.0.21 

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

func (*SettingsReply) XXX_Merge added in v0.0.21 

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

func (*SettingsReply) XXX_Size added in v0.0.21 

func (m *SettingsReply) XXX_Size() int

func (*SettingsReply) XXX_Unmarshal added in v0.0.21 

func (m *SettingsReply) 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 StorageClient added in v0.0.22 

type StorageClient interface {
	UploadFile(ctx context.Context, opts ...grpc.CallOption) (Storage_UploadFileClient, error)
}

StorageClient is the client API for Storage service.

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

func NewStorageClient added in v0.0.22 

func NewStorageClient(cc *grpc.ClientConn) StorageClient

type StorageServer added in v0.0.22 

type StorageServer interface {
	UploadFile(Storage_UploadFileServer) error
}

StorageServer is the server API for Storage service.

type Storage_UploadFileClient added in v0.0.22 

type Storage_UploadFileClient interface {
	Send(*FileRequest) error
	CloseAndRecv() (*FileReply, error)
	grpc.ClientStream
}

type Storage_UploadFileServer added in v0.0.22 

type Storage_UploadFileServer interface {
	SendAndClose(*FileReply) error
	Recv() (*FileRequest, error)
	grpc.ServerStream
}

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 TaskClient added in v0.0.17 

type TaskClient interface {
	Send(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*StateReply, error)
	Delay(ctx context.Context, in *JobRequest, opts ...grpc.CallOption) (*StateReply, error)
}

TaskClient is the client API for Task service.

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

func NewTaskClient added in v0.0.17 

func NewTaskClient(cc *grpc.ClientConn) TaskClient

type TaskServer added in v0.0.17 

type TaskServer interface {
	Send(context.Context, *JobRequest) (*StateReply, error)
	Delay(context.Context, *JobRequest) (*StateReply, error)
}

TaskServer is the server API for Task 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 TextsReply added in v0.0.18 

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

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

func (*TextsReply) GetId added in v0.0.18 

func (m *TextsReply) GetId() int64

func (*TextsReply) GetText added in v0.0.18 

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

func (*TextsReply) GetUuid added in v0.0.18 

func (m *TextsReply) GetUuid() string

func (*TextsReply) ProtoMessage added in v0.0.18 

func (*TextsReply) ProtoMessage()

func (*TextsReply) Reset added in v0.0.18 

func (m *TextsReply) Reset()

func (*TextsReply) String added in v0.0.18 

func (m *TextsReply) String() string

func (*TextsReply) XXX_DiscardUnknown added in v0.0.18 

func (m *TextsReply) XXX_DiscardUnknown()

func (*TextsReply) XXX_Marshal added in v0.0.18 

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

func (*TextsReply) XXX_Merge added in v0.0.18 

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

func (*TextsReply) XXX_Size added in v0.0.18 

func (m *TextsReply) XXX_Size() int

func (*TextsReply) XXX_Unmarshal added in v0.0.18 

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

type TriggerRequest added in v0.0.18 

type TriggerRequest struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Kind                 string   `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Flag                 string   `protobuf:"bytes,3,opt,name=flag,proto3" json:"flag,omitempty"`
	Secret               string   `protobuf:"bytes,4,opt,name=secret,proto3" json:"secret,omitempty"`
	Header               string   `protobuf:"bytes,5,opt,name=header,proto3" json:"header,omitempty"`
	Body                 string   `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	MessageId            int64    `protobuf:"varint,7,opt,name=messageId,proto3" json:"messageId,omitempty"`
	MessageText          string   `protobuf:"bytes,8,opt,name=messageText,proto3" json:"messageText,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TriggerRequest) Descriptor added in v0.0.18 

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

func (*TriggerRequest) GetBody added in v0.0.18 

func (m *TriggerRequest) GetBody() string

func (*TriggerRequest) GetFlag added in v0.0.18 

func (m *TriggerRequest) GetFlag() string

func (*TriggerRequest) GetHeader added in v0.0.18 

func (m *TriggerRequest) GetHeader() string

func (*TriggerRequest) GetKind added in v0.0.18 

func (m *TriggerRequest) GetKind() string

func (*TriggerRequest) GetMessageId added in v0.0.18 

func (m *TriggerRequest) GetMessageId() int64

func (*TriggerRequest) GetMessageText added in v0.0.18 

func (m *TriggerRequest) GetMessageText() string

func (*TriggerRequest) GetSecret added in v0.0.18 

func (m *TriggerRequest) GetSecret() string

func (*TriggerRequest) GetType added in v0.0.18 

func (m *TriggerRequest) GetType() string

func (*TriggerRequest) ProtoMessage added in v0.0.18 

func (*TriggerRequest) ProtoMessage()

func (*TriggerRequest) Reset added in v0.0.18 

func (m *TriggerRequest) Reset()

func (*TriggerRequest) String added in v0.0.18 

func (m *TriggerRequest) String() string

func (*TriggerRequest) XXX_DiscardUnknown added in v0.0.18 

func (m *TriggerRequest) XXX_DiscardUnknown()

func (*TriggerRequest) XXX_Marshal added in v0.0.18 

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

func (*TriggerRequest) XXX_Merge added in v0.0.18 

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

func (*TriggerRequest) XXX_Size added in v0.0.18 

func (m *TriggerRequest) XXX_Size() int

func (*TriggerRequest) XXX_Unmarshal added in v0.0.18 

func (m *TriggerRequest) 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) (*TextsReply, error)

func (*UnimplementedMessageServer) CreateActionMessage added in v0.0.17 

func (*UnimplementedMessageServer) CreateActionMessage(ctx context.Context, req *TextRequest) (*StateReply, error)

func (*UnimplementedMessageServer) Delete 

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

func (*UnimplementedMessageServer) DeleteWorkflowMessage added in v0.0.18 

func (*UnimplementedMessageServer) DeleteWorkflowMessage(ctx context.Context, req *MessageRequest) (*StateReply, error)

func (*UnimplementedMessageServer) Get 

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

func (*UnimplementedMessageServer) GetActionMessages added in v0.0.17 

func (*UnimplementedMessageServer) GetActionMessages(ctx context.Context, req *TextRequest) (*ActionReply, 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) (*StateReply, error)

type UnimplementedMiddleServer 

type UnimplementedMiddleServer struct {
}

UnimplementedMiddleServer can be embedded to have forward compatible implementations.

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) (*StateReply, 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) (*StateReply, error)

func (*UnimplementedMiddleServer) GetApps added in v0.0.17 

func (*UnimplementedMiddleServer) GetApps(ctx context.Context, req *TextRequest) (*AppsReply, error)

func (*UnimplementedMiddleServer) GetAvailableApp added in v0.0.15 

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

func (*UnimplementedMiddleServer) GetCredential added in v0.0.15 

func (*UnimplementedMiddleServer) GetCredential(ctx context.Context, req *CredentialRequest) (*CredentialReply, error)

func (*UnimplementedMiddleServer) GetCredentials added in v0.0.9 

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

func (*UnimplementedMiddleServer) GetMaskingCredentials added in v0.0.17 

func (*UnimplementedMiddleServer) GetMaskingCredentials(ctx context.Context, req *TextRequest) (*MaskingReply, 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) GetQrUrl added in v0.0.17 

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

func (*UnimplementedMiddleServer) GetSetting added in v0.0.9 

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

func (*UnimplementedMiddleServer) GetSettings added in v0.0.21 

func (*UnimplementedMiddleServer) GetSettings(ctx context.Context, req *TextRequest) (*SettingsReply, error)

func (*UnimplementedMiddleServer) GetStats added in v0.0.22 

func (*UnimplementedMiddleServer) GetStats(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 UnimplementedStorageServer added in v0.0.22 

type UnimplementedStorageServer struct {
}

UnimplementedStorageServer can be embedded to have forward compatible implementations.

func (*UnimplementedStorageServer) UploadFile added in v0.0.22 

func (*UnimplementedStorageServer) UploadFile(srv Storage_UploadFileServer) 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 UnimplementedTaskServer added in v0.0.17 

type UnimplementedTaskServer struct {
}

UnimplementedTaskServer can be embedded to have forward compatible implementations.

func (*UnimplementedTaskServer) Delay added in v0.0.20 

func (*UnimplementedTaskServer) Delay(ctx context.Context, req *JobRequest) (*StateReply, error)

func (*UnimplementedTaskServer) Send added in v0.0.17 

func (*UnimplementedTaskServer) Send(ctx context.Context, req *JobRequest) (*StateReply, error)

type UnimplementedWorkflowServer added in v0.0.9 

type UnimplementedWorkflowServer struct {
}

UnimplementedWorkflowServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowServer) ActionDoc added in v0.0.19 

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

func (*UnimplementedWorkflowServer) CreateTrigger added in v0.0.18 

func (*UnimplementedWorkflowServer) CreateTrigger(ctx context.Context, req *TriggerRequest) (*StateReply, error)

func (*UnimplementedWorkflowServer) CronTrigger added in v0.0.18 

func (*UnimplementedWorkflowServer) CronTrigger(ctx context.Context, req *TriggerRequest) (*WorkflowReply, error)

func (*UnimplementedWorkflowServer) DeleteTrigger added in v0.0.18 

func (*UnimplementedWorkflowServer) DeleteTrigger(ctx context.Context, req *TriggerRequest) (*StateReply, error)

func (*UnimplementedWorkflowServer) RunAction added in v0.0.16 

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

func (*UnimplementedWorkflowServer) SyntaxCheck added in v0.0.18 

func (*UnimplementedWorkflowServer) SyntaxCheck(ctx context.Context, req *WorkflowRequest) (*StateReply, error)

func (*UnimplementedWorkflowServer) WebhookTrigger added in v0.0.18 

func (*UnimplementedWorkflowServer) WebhookTrigger(ctx context.Context, req *TriggerRequest) (*WorkflowReply, error)

type WorkflowClient added in v0.0.9 

type WorkflowClient interface {
	SyntaxCheck(ctx context.Context, in *WorkflowRequest, opts ...grpc.CallOption) (*StateReply, error)
	RunAction(ctx context.Context, in *WorkflowRequest, opts ...grpc.CallOption) (*WorkflowReply, error)
	WebhookTrigger(ctx context.Context, in *TriggerRequest, opts ...grpc.CallOption) (*WorkflowReply, error)
	CronTrigger(ctx context.Context, in *TriggerRequest, opts ...grpc.CallOption) (*WorkflowReply, error)
	CreateTrigger(ctx context.Context, in *TriggerRequest, opts ...grpc.CallOption) (*StateReply, error)
	DeleteTrigger(ctx context.Context, in *TriggerRequest, opts ...grpc.CallOption) (*StateReply, error)
	ActionDoc(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"`
	Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,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) GetType added in v0.0.18 

func (m *WorkflowRequest) GetType() 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 {
	SyntaxCheck(context.Context, *WorkflowRequest) (*StateReply, error)
	RunAction(context.Context, *WorkflowRequest) (*WorkflowReply, error)
	WebhookTrigger(context.Context, *TriggerRequest) (*WorkflowReply, error)
	CronTrigger(context.Context, *TriggerRequest) (*WorkflowReply, error)
	CreateTrigger(context.Context, *TriggerRequest) (*StateReply, error)
	DeleteTrigger(context.Context, *TriggerRequest) (*StateReply, error)
	ActionDoc(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.