schedulespb

type ClientMessage struct {

	// globally unique ID of the request/response pair
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ClientMessage_RegistrationRequest
	//	*ClientMessage_IntervalResponse
	Content isClientMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type ClientMessage_IntervalResponse struct {
	// Response to a schedule interval (i.e. response from callback function)
	IntervalResponse *IntervalResponse `protobuf:"bytes,3,opt,name=interval_response,json=intervalResponse,proto3,oneof"`
}

type ClientMessage_RegistrationRequest struct {
	// Register new a schedule
	RegistrationRequest *RegistrationRequest `protobuf:"bytes,2,opt,name=registration_request,json=registrationRequest,proto3,oneof"`
}

type IntervalRequest struct {
	ScheduleName string `protobuf:"bytes,1,opt,name=schedule_name,json=scheduleName,proto3" json:"schedule_name,omitempty"`
	// contains filtered or unexported fields
}

type IntervalResponse struct {
	// contains filtered or unexported fields
}

type RegistrationRequest struct {
	ScheduleName string `protobuf:"bytes,1,opt,name=schedule_name,json=scheduleName,proto3" json:"schedule_name,omitempty"`
	// Types that are assignable to Cadence:
	//
	//	*RegistrationRequest_Every
	//	*RegistrationRequest_Cron
	Cadence isRegistrationRequest_Cadence `protobuf_oneof:"cadence"`
	// contains filtered or unexported fields
}

type RegistrationRequest_Cron struct {
	Cron *ScheduleCron `protobuf:"bytes,11,opt,name=cron,proto3,oneof"`
}

type RegistrationRequest_Every struct {
	Every *ScheduleEvery `protobuf:"bytes,10,opt,name=every,proto3,oneof"`
}

type RegistrationResponse struct {
	// contains filtered or unexported fields
}

type ScheduleCron struct {
	Expression string `protobuf:"bytes,1,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

type ScheduleEvery struct {
	Rate string `protobuf:"bytes,1,opt,name=rate,proto3" json:"rate,omitempty"`
	// contains filtered or unexported fields
}

type SchedulesClient interface {
	Schedule(ctx context.Context, opts ...grpc.CallOption) (Schedules_ScheduleClient, error)
}

type SchedulesServer interface {
	Schedule(Schedules_ScheduleServer) error
}

type Schedules_ScheduleClient interface {
	Send(*ClientMessage) error
	Recv() (*ServerMessage, error)
	grpc.ClientStream
}

type Schedules_ScheduleServer interface {
	Send(*ServerMessage) error
	Recv() (*ClientMessage, error)
	grpc.ServerStream
}

type ServerMessage struct {

	// globally unique ID of the request/response pair
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ServerMessage_RegistrationResponse
	//	*ServerMessage_IntervalRequest
	Content isServerMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type ServerMessage_IntervalRequest struct {
	// A schedule interval trigger request (i.e. call the callback)
	IntervalRequest *IntervalRequest `protobuf:"bytes,3,opt,name=interval_request,json=intervalRequest,proto3,oneof"`
}

type ServerMessage_RegistrationResponse struct {
	// Response to a schedule subscription request
	RegistrationResponse *RegistrationResponse `protobuf:"bytes,2,opt,name=registration_response,json=registrationResponse,proto3,oneof"`
}

type UnimplementedSchedulesServer struct {
}

type UnsafeSchedulesServer interface {
	// contains filtered or unexported methods
}