com_cyto_scheduler

package
v0.0.0-...-d5b5604 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2019 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ScheduledTask_EventType_name = map[int32]string{
	0: "CHANNEL_REMINDER",
	1: "DIRECT_REMINDER",
}
View Source 
var ScheduledTask_EventType_value = map[string]int32{
	"CHANNEL_REMINDER": 0,
	"DIRECT_REMINDER":  1,
}
View Source 
var ScheduledTask_IntervalType_name = map[int32]string{
	0: "NONE",
	1: "SECONDS",
	2: "MINUTES",
	3: "HOURS",
	4: "DAYS",
	5: "WEEKS",
	6: "MONTHS",
	7: "YEARS",
}
View Source 
var ScheduledTask_IntervalType_value = map[string]int32{
	"NONE":    0,
	"SECONDS": 1,
	"MINUTES": 2,
	"HOURS":   3,
	"DAYS":    4,
	"WEEKS":   5,
	"MONTHS":  6,
	"YEARS":   7,
}

Functions

func RegisterSchedulerServer 

func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer)

Types

type GuildQuery 

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

func (*GuildQuery) Descriptor 

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

func (*GuildQuery) GetGuildID 

func (m *GuildQuery) GetGuildID() string

func (*GuildQuery) ProtoMessage 

func (*GuildQuery) ProtoMessage()

func (*GuildQuery) Reset 

func (m *GuildQuery) Reset()

func (*GuildQuery) String 

func (m *GuildQuery) String() string

func (*GuildQuery) XXX_DiscardUnknown 

func (m *GuildQuery) XXX_DiscardUnknown()

func (*GuildQuery) XXX_Marshal 

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

func (*GuildQuery) XXX_Merge 

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

func (*GuildQuery) XXX_Size 

func (m *GuildQuery) XXX_Size() int

func (*GuildQuery) XXX_Unmarshal 

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

type ScheduledTask 

type ScheduledTask struct {
	ScheduledTaskID      string                     `protobuf:"bytes,1,opt,name=scheduledTaskID,proto3" json:"scheduledTaskID,omitempty"`
	CreatedUserID        string                     `protobuf:"bytes,2,opt,name=createdUserID,proto3" json:"createdUserID,omitempty"`
	CreatedDateUtc       *timestamp.Timestamp       `protobuf:"bytes,3,opt,name=createdDateUtc,proto3" json:"createdDateUtc,omitempty"`
	GuildID              string                     `protobuf:"bytes,4,opt,name=guildID,proto3" json:"guildID,omitempty"`
	ChannelID            string                     `protobuf:"bytes,5,opt,name=channelID,proto3" json:"channelID,omitempty"`
	IntervalType         ScheduledTask_IntervalType `` /* 129-byte string literal not displayed */
	Interval             int32                      `protobuf:"varint,7,opt,name=interval,proto3" json:"interval,omitempty"`
	EventType            ScheduledTask_EventType    `protobuf:"varint,8,opt,name=eventType,proto3,enum=com.cyto.scheduler.ScheduledTask_EventType" json:"eventType,omitempty"`
	AdditionalPayload    string                     `protobuf:"bytes,9,opt,name=additionalPayload,proto3" json:"additionalPayload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ScheduledTask) Descriptor 

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

func (*ScheduledTask) GetAdditionalPayload 

func (m *ScheduledTask) GetAdditionalPayload() string

func (*ScheduledTask) GetChannelID 

func (m *ScheduledTask) GetChannelID() string

func (*ScheduledTask) GetCreatedDateUtc 

func (m *ScheduledTask) GetCreatedDateUtc() *timestamp.Timestamp

func (*ScheduledTask) GetCreatedUserID 

func (m *ScheduledTask) GetCreatedUserID() string

func (*ScheduledTask) GetEventType 

func (m *ScheduledTask) GetEventType() ScheduledTask_EventType

func (*ScheduledTask) GetGuildID 

func (m *ScheduledTask) GetGuildID() string

func (*ScheduledTask) GetInterval 

func (m *ScheduledTask) GetInterval() int32

func (*ScheduledTask) GetIntervalType 

func (m *ScheduledTask) GetIntervalType() ScheduledTask_IntervalType

func (*ScheduledTask) GetScheduledTaskID 

func (m *ScheduledTask) GetScheduledTaskID() string

func (*ScheduledTask) ProtoMessage 

func (*ScheduledTask) ProtoMessage()

func (*ScheduledTask) Reset 

func (m *ScheduledTask) Reset()

func (*ScheduledTask) String 

func (m *ScheduledTask) String() string

func (*ScheduledTask) XXX_DiscardUnknown 

func (m *ScheduledTask) XXX_DiscardUnknown()

func (*ScheduledTask) XXX_Marshal 

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

func (*ScheduledTask) XXX_Merge 

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

func (*ScheduledTask) XXX_Size 

func (m *ScheduledTask) XXX_Size() int

func (*ScheduledTask) XXX_Unmarshal 

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

type ScheduledTaskList 

type ScheduledTaskList struct {
	Tasks                []*ScheduledTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ScheduledTaskList) Descriptor 

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

func (*ScheduledTaskList) GetTasks 

func (m *ScheduledTaskList) GetTasks() []*ScheduledTask

func (*ScheduledTaskList) ProtoMessage 

func (*ScheduledTaskList) ProtoMessage()

func (*ScheduledTaskList) Reset 

func (m *ScheduledTaskList) Reset()

func (*ScheduledTaskList) String 

func (m *ScheduledTaskList) String() string

func (*ScheduledTaskList) XXX_DiscardUnknown 

func (m *ScheduledTaskList) XXX_DiscardUnknown()

func (*ScheduledTaskList) XXX_Marshal 

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

func (*ScheduledTaskList) XXX_Merge 

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

func (*ScheduledTaskList) XXX_Size 

func (m *ScheduledTaskList) XXX_Size() int

func (*ScheduledTaskList) XXX_Unmarshal 

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

type ScheduledTaskQuery 

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

func (*ScheduledTaskQuery) Descriptor 

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

func (*ScheduledTaskQuery) GetScheduledTaskID 

func (m *ScheduledTaskQuery) GetScheduledTaskID() string

func (*ScheduledTaskQuery) ProtoMessage 

func (*ScheduledTaskQuery) ProtoMessage()

func (*ScheduledTaskQuery) Reset 

func (m *ScheduledTaskQuery) Reset()

func (*ScheduledTaskQuery) String 

func (m *ScheduledTaskQuery) String() string

func (*ScheduledTaskQuery) XXX_DiscardUnknown 

func (m *ScheduledTaskQuery) XXX_DiscardUnknown()

func (*ScheduledTaskQuery) XXX_Marshal 

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

func (*ScheduledTaskQuery) XXX_Merge 

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

func (*ScheduledTaskQuery) XXX_Size 

func (m *ScheduledTaskQuery) XXX_Size() int

func (*ScheduledTaskQuery) XXX_Unmarshal 

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

type ScheduledTask_EventType 

type ScheduledTask_EventType int32
const (
	ScheduledTask_CHANNEL_REMINDER ScheduledTask_EventType = 0
	ScheduledTask_DIRECT_REMINDER  ScheduledTask_EventType = 1
)

func (ScheduledTask_EventType) EnumDescriptor 

func (ScheduledTask_EventType) EnumDescriptor() ([]byte, []int)

func (ScheduledTask_EventType) String 

func (x ScheduledTask_EventType) String() string

type ScheduledTask_IntervalType 

type ScheduledTask_IntervalType int32
const (
	ScheduledTask_NONE    ScheduledTask_IntervalType = 0
	ScheduledTask_SECONDS ScheduledTask_IntervalType = 1
	ScheduledTask_MINUTES ScheduledTask_IntervalType = 2
	ScheduledTask_HOURS   ScheduledTask_IntervalType = 3
	ScheduledTask_DAYS    ScheduledTask_IntervalType = 4
	ScheduledTask_WEEKS   ScheduledTask_IntervalType = 5
	ScheduledTask_MONTHS  ScheduledTask_IntervalType = 6
	ScheduledTask_YEARS   ScheduledTask_IntervalType = 7
)

func (ScheduledTask_IntervalType) EnumDescriptor 

func (ScheduledTask_IntervalType) EnumDescriptor() ([]byte, []int)

func (ScheduledTask_IntervalType) String 

func (x ScheduledTask_IntervalType) String() string

type SchedulerClient 

type SchedulerClient interface {
	SetScheduledTask(ctx context.Context, in *ScheduledTask, opts ...grpc.CallOption) (*ScheduledTask, error)
	GetScheduledTask(ctx context.Context, in *ScheduledTaskQuery, opts ...grpc.CallOption) (*ScheduledTask, error)
	GetScheduledTasksForGuild(ctx context.Context, in *GuildQuery, opts ...grpc.CallOption) (*ScheduledTaskList, error)
	GetScheduledTasksForUser(ctx context.Context, in *UserQuery, opts ...grpc.CallOption) (*ScheduledTaskList, error)
	RemoveScheduledTask(ctx context.Context, in *ScheduledTaskQuery, opts ...grpc.CallOption) (*ScheduledTask, error)
	RemoveAllScheduledTasksForGuild(ctx context.Context, in *GuildQuery, opts ...grpc.CallOption) (*ScheduledTaskList, error)
	RemoveAllScheduledTasksForUser(ctx context.Context, in *UserQuery, opts ...grpc.CallOption) (*ScheduledTaskList, error)
}

SchedulerClient is the client API for Scheduler service.

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

func NewSchedulerClient 

func NewSchedulerClient(cc *grpc.ClientConn) SchedulerClient

type SchedulerServer 

type SchedulerServer interface {
	SetScheduledTask(context.Context, *ScheduledTask) (*ScheduledTask, error)
	GetScheduledTask(context.Context, *ScheduledTaskQuery) (*ScheduledTask, error)
	GetScheduledTasksForGuild(context.Context, *GuildQuery) (*ScheduledTaskList, error)
	GetScheduledTasksForUser(context.Context, *UserQuery) (*ScheduledTaskList, error)
	RemoveScheduledTask(context.Context, *ScheduledTaskQuery) (*ScheduledTask, error)
	RemoveAllScheduledTasksForGuild(context.Context, *GuildQuery) (*ScheduledTaskList, error)
	RemoveAllScheduledTasksForUser(context.Context, *UserQuery) (*ScheduledTaskList, error)
}

SchedulerServer is the server API for Scheduler service.

type UnimplementedSchedulerServer 

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulerServer) GetScheduledTask 

func (*UnimplementedSchedulerServer) GetScheduledTask(ctx context.Context, req *ScheduledTaskQuery) (*ScheduledTask, error)

func (*UnimplementedSchedulerServer) GetScheduledTasksForGuild 

func (*UnimplementedSchedulerServer) GetScheduledTasksForGuild(ctx context.Context, req *GuildQuery) (*ScheduledTaskList, error)

func (*UnimplementedSchedulerServer) GetScheduledTasksForUser 

func (*UnimplementedSchedulerServer) GetScheduledTasksForUser(ctx context.Context, req *UserQuery) (*ScheduledTaskList, error)

func (*UnimplementedSchedulerServer) RemoveAllScheduledTasksForGuild 

func (*UnimplementedSchedulerServer) RemoveAllScheduledTasksForGuild(ctx context.Context, req *GuildQuery) (*ScheduledTaskList, error)

func (*UnimplementedSchedulerServer) RemoveAllScheduledTasksForUser 

func (*UnimplementedSchedulerServer) RemoveAllScheduledTasksForUser(ctx context.Context, req *UserQuery) (*ScheduledTaskList, error)

func (*UnimplementedSchedulerServer) RemoveScheduledTask 

func (*UnimplementedSchedulerServer) RemoveScheduledTask(ctx context.Context, req *ScheduledTaskQuery) (*ScheduledTask, error)

func (*UnimplementedSchedulerServer) SetScheduledTask 

func (*UnimplementedSchedulerServer) SetScheduledTask(ctx context.Context, req *ScheduledTask) (*ScheduledTask, error)

type UserQuery 

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

func (*UserQuery) Descriptor 

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

func (*UserQuery) GetUserID 

func (m *UserQuery) GetUserID() string

func (*UserQuery) ProtoMessage 

func (*UserQuery) ProtoMessage()

func (*UserQuery) Reset 

func (m *UserQuery) Reset()

func (*UserQuery) String 

func (m *UserQuery) String() string

func (*UserQuery) XXX_DiscardUnknown 

func (m *UserQuery) XXX_DiscardUnknown()

func (*UserQuery) XXX_Marshal 

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

func (*UserQuery) XXX_Merge 

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

func (*UserQuery) XXX_Size 

func (m *UserQuery) XXX_Size() int

func (*UserQuery) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.