api

package
v1.2.2 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Event_Mode_name = map[int32]string{
	0: "TIMESTAMP",
	1: "CRON",
}
View Source 
var Event_Mode_value = map[string]int32{
	"TIMESTAMP": 0,
	"CRON":      1,
}

Functions

func RegisterSchedulerServer 

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

Types

type Event 

type Event struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CronExpression string `protobuf:"bytes,2,opt,name=cron_expression,json=cronExpression,proto3" json:"cron_expression,omitempty"`
	// Unix timestamp
	ShouldExecuteAt      int64      `protobuf:"varint,3,opt,name=should_execute_at,json=shouldExecuteAt,proto3" json:"should_execute_at,omitempty"`
	Mode                 Event_Mode `protobuf:"varint,4,opt,name=mode,proto3,enum=api.Event_Mode" json:"mode,omitempty"`
	Topic                string     `protobuf:"bytes,5,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload              []byte     `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Event) Descriptor 

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

func (*Event) GetCronExpression 

func (m *Event) GetCronExpression() string

func (*Event) GetId 

func (m *Event) GetId() string

func (*Event) GetMode 

func (m *Event) GetMode() Event_Mode

func (*Event) GetPayload 

func (m *Event) GetPayload() []byte

func (*Event) GetShouldExecuteAt 

func (m *Event) GetShouldExecuteAt() int64

func (*Event) GetTopic 

func (m *Event) GetTopic() string

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Event_ID 

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

func (*Event_ID) Descriptor 

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

func (*Event_ID) GetId 

func (m *Event_ID) GetId() string

func (*Event_ID) ProtoMessage 

func (*Event_ID) ProtoMessage()

func (*Event_ID) Reset 

func (m *Event_ID) Reset()

func (*Event_ID) String 

func (m *Event_ID) String() string

func (*Event_ID) XXX_DiscardUnknown 

func (m *Event_ID) XXX_DiscardUnknown()

func (*Event_ID) XXX_Marshal 

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

func (*Event_ID) XXX_Merge 

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

func (*Event_ID) XXX_Size 

func (m *Event_ID) XXX_Size() int

func (*Event_ID) XXX_Unmarshal 

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

type Event_Mode 

type Event_Mode int32
const (
	Event_TIMESTAMP Event_Mode = 0
	Event_CRON      Event_Mode = 1
)

func (Event_Mode) EnumDescriptor 

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

func (Event_Mode) String 

func (x Event_Mode) String() string

type ScheduleRequest 

type ScheduleRequest struct {
	Event                *Event   `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScheduleRequest) Descriptor 

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

func (*ScheduleRequest) GetEvent 

func (m *ScheduleRequest) GetEvent() *Event

func (*ScheduleRequest) ProtoMessage 

func (*ScheduleRequest) ProtoMessage()

func (*ScheduleRequest) Reset 

func (m *ScheduleRequest) Reset()

func (*ScheduleRequest) String 

func (m *ScheduleRequest) String() string

func (*ScheduleRequest) XXX_DiscardUnknown 

func (m *ScheduleRequest) XXX_DiscardUnknown()

func (*ScheduleRequest) XXX_Marshal 

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

func (*ScheduleRequest) XXX_Merge 

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

func (*ScheduleRequest) XXX_Size 

func (m *ScheduleRequest) XXX_Size() int

func (*ScheduleRequest) XXX_Unmarshal 

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

type ScheduleResponse 

type ScheduleResponse struct {
	Id                   *Event_ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ScheduleResponse) Descriptor 

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

func (*ScheduleResponse) GetId 

func (m *ScheduleResponse) GetId() *Event_ID

func (*ScheduleResponse) ProtoMessage 

func (*ScheduleResponse) ProtoMessage()

func (*ScheduleResponse) Reset 

func (m *ScheduleResponse) Reset()

func (*ScheduleResponse) String 

func (m *ScheduleResponse) String() string

func (*ScheduleResponse) XXX_DiscardUnknown 

func (m *ScheduleResponse) XXX_DiscardUnknown()

func (*ScheduleResponse) XXX_Marshal 

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

func (*ScheduleResponse) XXX_Merge 

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

func (*ScheduleResponse) XXX_Size 

func (m *ScheduleResponse) XXX_Size() int

func (*ScheduleResponse) XXX_Unmarshal 

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

type SchedulerClient 

type SchedulerClient interface {
	Schedule(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*ScheduleResponse, error)
	Unschedule(ctx context.Context, in *UnscheduleRequest, opts ...grpc.CallOption) (*UnscheduleResponse, error)
	StreamEvents(ctx context.Context, in *StreamEventsRequest, opts ...grpc.CallOption) (Scheduler_StreamEventsClient, 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.ClientConnInterface) SchedulerClient

type SchedulerServer 

type SchedulerServer interface {
	Schedule(context.Context, *ScheduleRequest) (*ScheduleResponse, error)
	Unschedule(context.Context, *UnscheduleRequest) (*UnscheduleResponse, error)
	StreamEvents(*StreamEventsRequest, Scheduler_StreamEventsServer) error
}

SchedulerServer is the server API for Scheduler service.

type Scheduler_StreamEventsClient 

type Scheduler_StreamEventsClient interface {
	Recv() (*StreamEventsResponse, error)
	grpc.ClientStream
}

type Scheduler_StreamEventsServer 

type Scheduler_StreamEventsServer interface {
	Send(*StreamEventsResponse) error
	grpc.ServerStream
}

type StreamEventsRequest 

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

func (*StreamEventsRequest) Descriptor 

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

func (*StreamEventsRequest) GetTopic 

func (m *StreamEventsRequest) GetTopic() string

func (*StreamEventsRequest) ProtoMessage 

func (*StreamEventsRequest) ProtoMessage()

func (*StreamEventsRequest) Reset 

func (m *StreamEventsRequest) Reset()

func (*StreamEventsRequest) String 

func (m *StreamEventsRequest) String() string

func (*StreamEventsRequest) XXX_DiscardUnknown 

func (m *StreamEventsRequest) XXX_DiscardUnknown()

func (*StreamEventsRequest) XXX_Marshal 

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

func (*StreamEventsRequest) XXX_Merge 

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

func (*StreamEventsRequest) XXX_Size 

func (m *StreamEventsRequest) XXX_Size() int

func (*StreamEventsRequest) XXX_Unmarshal 

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

type StreamEventsResponse 

type StreamEventsResponse struct {
	Event                *Event   `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamEventsResponse) Descriptor 

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

func (*StreamEventsResponse) GetEvent 

func (m *StreamEventsResponse) GetEvent() *Event

func (*StreamEventsResponse) ProtoMessage 

func (*StreamEventsResponse) ProtoMessage()

func (*StreamEventsResponse) Reset 

func (m *StreamEventsResponse) Reset()

func (*StreamEventsResponse) String 

func (m *StreamEventsResponse) String() string

func (*StreamEventsResponse) XXX_DiscardUnknown 

func (m *StreamEventsResponse) XXX_DiscardUnknown()

func (*StreamEventsResponse) XXX_Marshal 

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

func (*StreamEventsResponse) XXX_Merge 

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

func (*StreamEventsResponse) XXX_Size 

func (m *StreamEventsResponse) XXX_Size() int

func (*StreamEventsResponse) XXX_Unmarshal 

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

type UnimplementedSchedulerServer 

type UnimplementedSchedulerServer struct {
}

UnimplementedSchedulerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSchedulerServer) Schedule 

func (*UnimplementedSchedulerServer) Schedule(ctx context.Context, req *ScheduleRequest) (*ScheduleResponse, error)

func (*UnimplementedSchedulerServer) StreamEvents 

func (*UnimplementedSchedulerServer) StreamEvents(req *StreamEventsRequest, srv Scheduler_StreamEventsServer) error

func (*UnimplementedSchedulerServer) Unschedule 

func (*UnimplementedSchedulerServer) Unschedule(ctx context.Context, req *UnscheduleRequest) (*UnscheduleResponse, error)

type UnscheduleRequest 

type UnscheduleRequest struct {
	Id                   *Event_ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*UnscheduleRequest) Descriptor 

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

func (*UnscheduleRequest) GetId 

func (m *UnscheduleRequest) GetId() *Event_ID

func (*UnscheduleRequest) ProtoMessage 

func (*UnscheduleRequest) ProtoMessage()

func (*UnscheduleRequest) Reset 

func (m *UnscheduleRequest) Reset()

func (*UnscheduleRequest) String 

func (m *UnscheduleRequest) String() string

func (*UnscheduleRequest) XXX_DiscardUnknown 

func (m *UnscheduleRequest) XXX_DiscardUnknown()

func (*UnscheduleRequest) XXX_Marshal 

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

func (*UnscheduleRequest) XXX_Merge 

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

func (*UnscheduleRequest) XXX_Size 

func (m *UnscheduleRequest) XXX_Size() int

func (*UnscheduleRequest) XXX_Unmarshal 

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

type UnscheduleResponse 

type UnscheduleResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UnscheduleResponse) Descriptor 

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

func (*UnscheduleResponse) ProtoMessage 

func (*UnscheduleResponse) ProtoMessage()

func (*UnscheduleResponse) Reset 

func (m *UnscheduleResponse) Reset()

func (*UnscheduleResponse) String 

func (m *UnscheduleResponse) String() string

func (*UnscheduleResponse) XXX_DiscardUnknown 

func (m *UnscheduleResponse) XXX_DiscardUnknown()

func (*UnscheduleResponse) XXX_Marshal 

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

func (*UnscheduleResponse) XXX_Merge 

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

func (*UnscheduleResponse) XXX_Size 

func (m *UnscheduleResponse) XXX_Size() int

func (*UnscheduleResponse) XXX_Unmarshal 

func (m *UnscheduleResponse) 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.