rpc

Aug 4, 2021

Changes in this version

+ type Auth struct

+ func (s *Auth) CheckSession(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

+ func (s *Auth) Login(ctx *edge.RequestCtx, req *auth.LoginRequest, res *auth.Authorization)

+ func (s *Auth) MustAuthorized(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

+ func (s *Auth) Register(ctx *edge.RequestCtx, req *auth.RegisterRequest, res *auth.Authorization)

Jul 18, 2021

Changes in this version

+ const C_Authorization

+ const C_Bool

+ const C_CreateRequest

+ const C_DeleteRequest

+ const C_GetRequest

+ const C_ListRequest

+ const C_LoginRequest

+ const C_RegisterRequest

+ const C_TaskManagerCreate

+ const C_TaskManagerDelete

+ const C_TaskManagerGet

+ const C_TaskManagerList

+ const C_TaskManagerLogin

+ const C_TaskManagerRegister

+ const C_TaskView

+ const C_TaskViewMany

+ var File_task_manager_proto protoreflect.FileDescriptor

+ var PoolAuthorization = poolAuthorization

+ var PoolBool = poolBool

+ var PoolCreateRequest = poolCreateRequest

+ var PoolDeleteRequest = poolDeleteRequest

+ var PoolGetRequest = poolGetRequest

+ var PoolListRequest = poolListRequest

+ var PoolLoginRequest = poolLoginRequest

+ var PoolRegisterRequest = poolRegisterRequest

+ var PoolTaskView = poolTaskView

+ var PoolTaskViewMany = poolTaskViewMany

+ func RegisterTaskManager(h ITaskManager, e *edge.Server, preHandlers ...edge.Handler)

+ func RegisterTaskManagerCli(h ITaskManagerCli, c edgec.Client, rootCmd *cobra.Command)

+ func RegisterTaskManagerWithFunc(h ITaskManager, e *edge.Server, handlerFunc func(c int64) []edge.Handler)

+ func TunnelRequestTaskManagerCreate(ctx *edge.RequestCtx, replicaSet uint64, req *CreateRequest, res *TaskView, ...) error

+ func TunnelRequestTaskManagerDelete(ctx *edge.RequestCtx, replicaSet uint64, req *DeleteRequest, res *Bool, ...) error

+ func TunnelRequestTaskManagerGet(ctx *edge.RequestCtx, replicaSet uint64, req *GetRequest, res *TaskView, ...) error

+ func TunnelRequestTaskManagerList(ctx *edge.RequestCtx, replicaSet uint64, req *ListRequest, res *TaskViewMany, ...) error

+ func TunnelRequestTaskManagerLogin(ctx *edge.RequestCtx, replicaSet uint64, req *LoginRequest, res *Authorization, ...) error

+ func TunnelRequestTaskManagerRegister(ctx *edge.RequestCtx, replicaSet uint64, req *RegisterRequest, ...) error

+ type Authorization struct

+ SessionID string

+ func (*Authorization) Descriptor() ([]byte, []int)

+ func (*Authorization) ProtoMessage()

+ func (x *Authorization) Clone() *Authorization

+ func (x *Authorization) DeepCopy(z *Authorization)

+ func (x *Authorization) GetSessionID() string

+ func (x *Authorization) Marshal() ([]byte, error)

+ func (x *Authorization) MarshalJSON() ([]byte, error)

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

+ func (x *Authorization) PushToContext(ctx *edge.RequestCtx)

+ func (x *Authorization) Reset()

+ func (x *Authorization) String() string

+ func (x *Authorization) Unmarshal(b []byte) error

+ func (x *Authorization) UnmarshalJSON(b []byte) error

+ type Bool struct

+ Result bool

+ func (*Bool) Descriptor() ([]byte, []int)

+ func (*Bool) ProtoMessage()

+ func (x *Bool) Clone() *Bool

+ func (x *Bool) DeepCopy(z *Bool)

+ func (x *Bool) GetResult() bool

+ func (x *Bool) Marshal() ([]byte, error)

+ func (x *Bool) MarshalJSON() ([]byte, error)

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

+ func (x *Bool) PushToContext(ctx *edge.RequestCtx)

+ func (x *Bool) Reset()

+ func (x *Bool) String() string

+ func (x *Bool) Unmarshal(b []byte) error

+ func (x *Bool) UnmarshalJSON(b []byte) error

+ type CreateRequest struct

+ DueDate int64

+ TODOs []string

+ Title string

+ func (*CreateRequest) Descriptor() ([]byte, []int)

+ func (*CreateRequest) ProtoMessage()

+ func (x *CreateRequest) Clone() *CreateRequest

+ func (x *CreateRequest) DeepCopy(z *CreateRequest)

+ func (x *CreateRequest) GetDueDate() int64

+ func (x *CreateRequest) GetTODOs() []string

+ func (x *CreateRequest) GetTitle() string

+ func (x *CreateRequest) Marshal() ([]byte, error)

+ func (x *CreateRequest) MarshalJSON() ([]byte, error)

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

+ func (x *CreateRequest) PushToContext(ctx *edge.RequestCtx)

+ func (x *CreateRequest) Reset()

+ func (x *CreateRequest) String() string

+ func (x *CreateRequest) Unmarshal(b []byte) error

+ func (x *CreateRequest) UnmarshalJSON(b []byte) error

+ type DeleteRequest struct

+ TaskID int64

+ func (*DeleteRequest) Descriptor() ([]byte, []int)

+ func (*DeleteRequest) ProtoMessage()

+ func (x *DeleteRequest) Clone() *DeleteRequest

+ func (x *DeleteRequest) DeepCopy(z *DeleteRequest)

+ func (x *DeleteRequest) GetTaskID() int64

+ func (x *DeleteRequest) Marshal() ([]byte, error)

+ func (x *DeleteRequest) MarshalJSON() ([]byte, error)

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

+ func (x *DeleteRequest) PushToContext(ctx *edge.RequestCtx)

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ func (x *DeleteRequest) Unmarshal(b []byte) error

+ func (x *DeleteRequest) UnmarshalJSON(b []byte) error

+ type GetRequest struct

+ TaskID int64

+ func (*GetRequest) Descriptor() ([]byte, []int)

+ func (*GetRequest) ProtoMessage()

+ func (x *GetRequest) Clone() *GetRequest

+ func (x *GetRequest) DeepCopy(z *GetRequest)

+ func (x *GetRequest) GetTaskID() int64

+ func (x *GetRequest) Marshal() ([]byte, error)

+ func (x *GetRequest) MarshalJSON() ([]byte, error)

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

+ func (x *GetRequest) PushToContext(ctx *edge.RequestCtx)

+ func (x *GetRequest) Reset()

+ func (x *GetRequest) String() string

+ func (x *GetRequest) Unmarshal(b []byte) error

+ func (x *GetRequest) UnmarshalJSON(b []byte) error

+ type ITaskManager interface

+ Create func(ctx *edge.RequestCtx, req *CreateRequest, res *TaskView)

+ Delete func(ctx *edge.RequestCtx, req *DeleteRequest, res *Bool)

+ Get func(ctx *edge.RequestCtx, req *GetRequest, res *TaskView)

+ List func(ctx *edge.RequestCtx, req *ListRequest, res *TaskViewMany)

+ Login func(ctx *edge.RequestCtx, req *LoginRequest, res *Authorization)

+ Register func(ctx *edge.RequestCtx, req *RegisterRequest, res *Authorization)

+ type ITaskManagerCli interface

+ Create func(cli *TaskManagerClient, cmd *cobra.Command, args []string) error

+ Delete func(cli *TaskManagerClient, cmd *cobra.Command, args []string) error

+ Get func(cli *TaskManagerClient, cmd *cobra.Command, args []string) error

+ List func(cli *TaskManagerClient, cmd *cobra.Command, args []string) error

+ Login func(cli *TaskManagerClient, cmd *cobra.Command, args []string) error

+ Register func(cli *TaskManagerClient, cmd *cobra.Command, args []string) error

+ type ListRequest struct

+ Limit int32

+ Offset int32

+ func (*ListRequest) Descriptor() ([]byte, []int)

+ func (*ListRequest) ProtoMessage()

+ func (x *ListRequest) Clone() *ListRequest

+ func (x *ListRequest) DeepCopy(z *ListRequest)

+ func (x *ListRequest) GetLimit() int32

+ func (x *ListRequest) GetOffset() int32

+ func (x *ListRequest) Marshal() ([]byte, error)

+ func (x *ListRequest) MarshalJSON() ([]byte, error)

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

+ func (x *ListRequest) PushToContext(ctx *edge.RequestCtx)

+ func (x *ListRequest) Reset()

+ func (x *ListRequest) String() string

+ func (x *ListRequest) Unmarshal(b []byte) error

+ func (x *ListRequest) UnmarshalJSON(b []byte) error

+ type LoginRequest struct

+ Password string

+ Username string

+ func (*LoginRequest) Descriptor() ([]byte, []int)

+ func (*LoginRequest) ProtoMessage()

+ func (x *LoginRequest) Clone() *LoginRequest

+ func (x *LoginRequest) DeepCopy(z *LoginRequest)

+ func (x *LoginRequest) GetPassword() string

+ func (x *LoginRequest) GetUsername() string

+ func (x *LoginRequest) Marshal() ([]byte, error)

+ func (x *LoginRequest) MarshalJSON() ([]byte, error)

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

+ func (x *LoginRequest) PushToContext(ctx *edge.RequestCtx)

+ func (x *LoginRequest) Reset()

+ func (x *LoginRequest) String() string

+ func (x *LoginRequest) Unmarshal(b []byte) error

+ func (x *LoginRequest) UnmarshalJSON(b []byte) error

+ type RegisterRequest struct

+ FirstName string

+ LastName string

+ Password string

+ Username string

+ func (*RegisterRequest) Descriptor() ([]byte, []int)

+ func (*RegisterRequest) ProtoMessage()

+ func (x *RegisterRequest) Clone() *RegisterRequest

+ func (x *RegisterRequest) DeepCopy(z *RegisterRequest)

+ func (x *RegisterRequest) GetFirstName() string

+ func (x *RegisterRequest) GetLastName() string

+ func (x *RegisterRequest) GetPassword() string

+ func (x *RegisterRequest) GetUsername() string

+ func (x *RegisterRequest) Marshal() ([]byte, error)

+ func (x *RegisterRequest) MarshalJSON() ([]byte, error)

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

+ func (x *RegisterRequest) PushToContext(ctx *edge.RequestCtx)

+ func (x *RegisterRequest) Reset()

+ func (x *RegisterRequest) String() string

+ func (x *RegisterRequest) Unmarshal(b []byte) error

+ func (x *RegisterRequest) UnmarshalJSON(b []byte) error

+ type TaskManager struct

+ func NewTaskManager(s rony.Store) *TaskManager

+ func (tm *TaskManager) CheckSession(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

+ func (tm *TaskManager) Create(ctx *edge.RequestCtx, req *CreateRequest, res *TaskView)

+ func (tm *TaskManager) Delete(ctx *edge.RequestCtx, req *DeleteRequest, res *Bool)

+ func (tm *TaskManager) Get(ctx *edge.RequestCtx, req *GetRequest, res *TaskView)

+ func (tm *TaskManager) List(ctx *edge.RequestCtx, req *ListRequest, res *TaskViewMany)

+ func (tm *TaskManager) Login(ctx *edge.RequestCtx, req *LoginRequest, res *Authorization)

+ func (tm *TaskManager) MustAuthorized(ctx *edge.RequestCtx, in *rony.MessageEnvelope)

+ func (tm *TaskManager) Register(ctx *edge.RequestCtx, req *RegisterRequest, res *Authorization)

+ type TaskManagerClient struct

+ func NewTaskManagerClient(ec edgec.Client) *TaskManagerClient

+ func (c *TaskManagerClient) Create(req *CreateRequest, kvs ...*rony.KeyValue) (*TaskView, error)

+ func (c *TaskManagerClient) Delete(req *DeleteRequest, kvs ...*rony.KeyValue) (*Bool, error)

+ func (c *TaskManagerClient) Get(req *GetRequest, kvs ...*rony.KeyValue) (*TaskView, error)

+ func (c *TaskManagerClient) List(req *ListRequest, kvs ...*rony.KeyValue) (*TaskViewMany, error)

+ func (c *TaskManagerClient) Login(req *LoginRequest, kvs ...*rony.KeyValue) (*Authorization, error)

+ func (c *TaskManagerClient) Register(req *RegisterRequest, kvs ...*rony.KeyValue) (*Authorization, error)

+ type TaskView struct

+ DueDate int64

+ ID int64

+ TODOs []string

+ Title string

+ func (*TaskView) Descriptor() ([]byte, []int)

+ func (*TaskView) ProtoMessage()

+ func (x *TaskView) Clone() *TaskView

+ func (x *TaskView) DeepCopy(z *TaskView)

+ func (x *TaskView) GetDueDate() int64

+ func (x *TaskView) GetID() int64

+ func (x *TaskView) GetTODOs() []string

+ func (x *TaskView) GetTitle() string

+ func (x *TaskView) Marshal() ([]byte, error)

+ func (x *TaskView) MarshalJSON() ([]byte, error)

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

+ func (x *TaskView) PushToContext(ctx *edge.RequestCtx)

+ func (x *TaskView) Reset()

+ func (x *TaskView) String() string

+ func (x *TaskView) Unmarshal(b []byte) error

+ func (x *TaskView) UnmarshalJSON(b []byte) error

+ type TaskViewMany struct

+ Tasks []*TaskView

+ func (*TaskViewMany) Descriptor() ([]byte, []int)

+ func (*TaskViewMany) ProtoMessage()

+ func (x *TaskViewMany) Clone() *TaskViewMany

+ func (x *TaskViewMany) DeepCopy(z *TaskViewMany)

+ func (x *TaskViewMany) GetTasks() []*TaskView

+ func (x *TaskViewMany) Marshal() ([]byte, error)

+ func (x *TaskViewMany) MarshalJSON() ([]byte, error)

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

+ func (x *TaskViewMany) PushToContext(ctx *edge.RequestCtx)

+ func (x *TaskViewMany) Reset()

+ func (x *TaskViewMany) String() string

+ func (x *TaskViewMany) Unmarshal(b []byte) error

+ func (x *TaskViewMany) UnmarshalJSON(b []byte) error