schedule

package
v0.0.0-...-242557f Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterScheduleServiceServer 

func RegisterScheduleServiceServer(s *grpc.Server, srv ScheduleServiceServer)

Types

type BrokerEvent 

type BrokerEvent struct {
	Topic                string   `protobuf:"bytes,1,opt,name=Topic,proto3" json:"Topic,omitempty"`
	Key                  string   `protobuf:"bytes,2,opt,name=Key,proto3" json:"Key,omitempty"`
	Message              string   `protobuf:"bytes,3,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BrokerEvent) Descriptor 

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

func (*BrokerEvent) GetKey 

func (m *BrokerEvent) GetKey() string

func (*BrokerEvent) GetMessage 

func (m *BrokerEvent) GetMessage() string

func (*BrokerEvent) GetTopic 

func (m *BrokerEvent) GetTopic() string

func (*BrokerEvent) ProtoMessage 

func (*BrokerEvent) ProtoMessage()

func (*BrokerEvent) Reset 

func (m *BrokerEvent) Reset()

func (*BrokerEvent) String 

func (m *BrokerEvent) String() string

func (*BrokerEvent) XXX_DiscardUnknown 

func (m *BrokerEvent) XXX_DiscardUnknown()

func (*BrokerEvent) XXX_Marshal 

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

func (*BrokerEvent) XXX_Merge 

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

func (*BrokerEvent) XXX_Size 

func (m *BrokerEvent) XXX_Size() int

func (*BrokerEvent) XXX_Unmarshal 

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

type CreateBrokerScheduleRequest 

type CreateBrokerScheduleRequest struct {
	Period               string       `protobuf:"bytes,1,opt,name=period,proto3" json:"period,omitempty"`
	Schedule             *Schedule    `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`
	BrokerEvent          *BrokerEvent `protobuf:"bytes,3,opt,name=brokerEvent,proto3" json:"brokerEvent,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*CreateBrokerScheduleRequest) Descriptor 

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

func (*CreateBrokerScheduleRequest) GetBrokerEvent 

func (m *CreateBrokerScheduleRequest) GetBrokerEvent() *BrokerEvent

func (*CreateBrokerScheduleRequest) GetPeriod 

func (m *CreateBrokerScheduleRequest) GetPeriod() string

func (*CreateBrokerScheduleRequest) GetSchedule 

func (m *CreateBrokerScheduleRequest) GetSchedule() *Schedule

func (*CreateBrokerScheduleRequest) ProtoMessage 

func (*CreateBrokerScheduleRequest) ProtoMessage()

func (*CreateBrokerScheduleRequest) Reset 

func (m *CreateBrokerScheduleRequest) Reset()

func (*CreateBrokerScheduleRequest) String 

func (m *CreateBrokerScheduleRequest) String() string

func (*CreateBrokerScheduleRequest) XXX_DiscardUnknown 

func (m *CreateBrokerScheduleRequest) XXX_DiscardUnknown()

func (*CreateBrokerScheduleRequest) XXX_Marshal 

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

func (*CreateBrokerScheduleRequest) XXX_Merge 

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

func (*CreateBrokerScheduleRequest) XXX_Size 

func (m *CreateBrokerScheduleRequest) XXX_Size() int

func (*CreateBrokerScheduleRequest) XXX_Unmarshal 

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

type CreateGrpcScheduleRequest 

type CreateGrpcScheduleRequest struct {
	Period               string    `protobuf:"bytes,1,opt,name=period,proto3" json:"period,omitempty"`
	Schedule             *Schedule `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`
	GrpcCall             *GrpcCall `protobuf:"bytes,3,opt,name=grpcCall,proto3" json:"grpcCall,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*CreateGrpcScheduleRequest) Descriptor 

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

func (*CreateGrpcScheduleRequest) GetGrpcCall 

func (m *CreateGrpcScheduleRequest) GetGrpcCall() *GrpcCall

func (*CreateGrpcScheduleRequest) GetPeriod 

func (m *CreateGrpcScheduleRequest) GetPeriod() string

func (*CreateGrpcScheduleRequest) GetSchedule 

func (m *CreateGrpcScheduleRequest) GetSchedule() *Schedule

func (*CreateGrpcScheduleRequest) ProtoMessage 

func (*CreateGrpcScheduleRequest) ProtoMessage()

func (*CreateGrpcScheduleRequest) Reset 

func (m *CreateGrpcScheduleRequest) Reset()

func (*CreateGrpcScheduleRequest) String 

func (m *CreateGrpcScheduleRequest) String() string

func (*CreateGrpcScheduleRequest) XXX_DiscardUnknown 

func (m *CreateGrpcScheduleRequest) XXX_DiscardUnknown()

func (*CreateGrpcScheduleRequest) XXX_Marshal 

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

func (*CreateGrpcScheduleRequest) XXX_Merge 

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

func (*CreateGrpcScheduleRequest) XXX_Size 

func (m *CreateGrpcScheduleRequest) XXX_Size() int

func (*CreateGrpcScheduleRequest) XXX_Unmarshal 

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

type GrpcCall 

type GrpcCall struct {
	ClientName           string   `protobuf:"bytes,1,opt,name=ClientName,proto3" json:"ClientName,omitempty"`
	MethodName           string   `protobuf:"bytes,2,opt,name=MethodName,proto3" json:"MethodName,omitempty"`
	PayloadStr           string   `protobuf:"bytes,3,opt,name=PayloadStr,proto3" json:"PayloadStr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GrpcCall) Descriptor 

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

func (*GrpcCall) GetClientName 

func (m *GrpcCall) GetClientName() string

func (*GrpcCall) GetMethodName 

func (m *GrpcCall) GetMethodName() string

func (*GrpcCall) GetPayloadStr 

func (m *GrpcCall) GetPayloadStr() string

func (*GrpcCall) ProtoMessage 

func (*GrpcCall) ProtoMessage()

func (*GrpcCall) Reset 

func (m *GrpcCall) Reset()

func (*GrpcCall) String 

func (m *GrpcCall) String() string

func (*GrpcCall) XXX_DiscardUnknown 

func (m *GrpcCall) XXX_DiscardUnknown()

func (*GrpcCall) XXX_Marshal 

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

func (*GrpcCall) XXX_Merge 

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

func (*GrpcCall) XXX_Size 

func (m *GrpcCall) XXX_Size() int

func (*GrpcCall) XXX_Unmarshal 

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

type ListScheduleRequest 

type ListScheduleRequest struct {
	Type                 int32    `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListScheduleRequest) Descriptor 

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

func (*ListScheduleRequest) GetType 

func (m *ListScheduleRequest) GetType() int32

func (*ListScheduleRequest) ProtoMessage 

func (*ListScheduleRequest) ProtoMessage()

func (*ListScheduleRequest) Reset 

func (m *ListScheduleRequest) Reset()

func (*ListScheduleRequest) String 

func (m *ListScheduleRequest) String() string

func (*ListScheduleRequest) XXX_DiscardUnknown 

func (m *ListScheduleRequest) XXX_DiscardUnknown()

func (*ListScheduleRequest) XXX_Marshal 

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

func (*ListScheduleRequest) XXX_Merge 

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

func (*ListScheduleRequest) XXX_Size 

func (m *ListScheduleRequest) XXX_Size() int

func (*ListScheduleRequest) XXX_Unmarshal 

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

type Schedule 

type Schedule struct {
	ScheduleName         string   `protobuf:"bytes,1,opt,name=scheduleName,proto3" json:"scheduleName,omitempty"`
	ScheduleComment      string   `protobuf:"bytes,2,opt,name=ScheduleComment,proto3" json:"ScheduleComment,omitempty"`
	Id                   int32    `protobuf:"varint,3,opt,name=Id,proto3" json:"Id,omitempty"`
	Any                  *any.Any `protobuf:"bytes,7,opt,name=any,proto3" json:"any,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Schedule) Descriptor 

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

func (*Schedule) GetAny 

func (m *Schedule) GetAny() *any.Any

func (*Schedule) GetId 

func (m *Schedule) GetId() int32

func (*Schedule) GetScheduleComment 

func (m *Schedule) GetScheduleComment() string

func (*Schedule) GetScheduleName 

func (m *Schedule) GetScheduleName() string

func (*Schedule) ProtoMessage 

func (*Schedule) ProtoMessage()

func (*Schedule) Reset 

func (m *Schedule) Reset()

func (*Schedule) String 

func (m *Schedule) String() string

func (*Schedule) XXX_DiscardUnknown 

func (m *Schedule) XXX_DiscardUnknown()

func (*Schedule) XXX_Marshal 

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

func (*Schedule) XXX_Merge 

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

func (*Schedule) XXX_Size 

func (m *Schedule) XXX_Size() int

func (*Schedule) XXX_Unmarshal 

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

type ScheduleServiceClient 

type ScheduleServiceClient interface {
	ListSchedule(ctx context.Context, in *ListScheduleRequest, opts ...grpc.CallOption) (ScheduleService_ListScheduleClient, error)
	CreateOneTimeGrpcSchedule(ctx context.Context, in *CreateGrpcScheduleRequest, opts ...grpc.CallOption) (*Schedule, error)
	CreateGrpcSchedule(ctx context.Context, in *CreateGrpcScheduleRequest, opts ...grpc.CallOption) (*Schedule, error)
	UpdateGrpcSchedule(ctx context.Context, in *UpdateGrpcScheduleRequest, opts ...grpc.CallOption) (*Schedule, error)
	CreateOneTimeBrokerSchedule(ctx context.Context, in *CreateBrokerScheduleRequest, opts ...grpc.CallOption) (*Schedule, error)
	CreateBrokerSchedule(ctx context.Context, in *CreateBrokerScheduleRequest, opts ...grpc.CallOption) (*Schedule, error)
	UpdateBrokerSchedule(ctx context.Context, in *UpdateBrokerScheduleRequest, opts ...grpc.CallOption) (*Schedule, error)
	CancelSchedule(ctx context.Context, in *Schedule, opts ...grpc.CallOption) (*Schedule, error)
}

ScheduleServiceClient is the client API for ScheduleService service.

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

func NewScheduleServiceClient 

func NewScheduleServiceClient(cc *grpc.ClientConn) ScheduleServiceClient

type ScheduleServiceServer 

type ScheduleServiceServer interface {
	ListSchedule(*ListScheduleRequest, ScheduleService_ListScheduleServer) error
	CreateOneTimeGrpcSchedule(context.Context, *CreateGrpcScheduleRequest) (*Schedule, error)
	CreateGrpcSchedule(context.Context, *CreateGrpcScheduleRequest) (*Schedule, error)
	UpdateGrpcSchedule(context.Context, *UpdateGrpcScheduleRequest) (*Schedule, error)
	CreateOneTimeBrokerSchedule(context.Context, *CreateBrokerScheduleRequest) (*Schedule, error)
	CreateBrokerSchedule(context.Context, *CreateBrokerScheduleRequest) (*Schedule, error)
	UpdateBrokerSchedule(context.Context, *UpdateBrokerScheduleRequest) (*Schedule, error)
	CancelSchedule(context.Context, *Schedule) (*Schedule, error)
}

ScheduleServiceServer is the server API for ScheduleService service.

type ScheduleService_ListScheduleClient 

type ScheduleService_ListScheduleClient interface {
	Recv() (*Schedule, error)
	grpc.ClientStream
}

type ScheduleService_ListScheduleServer 

type ScheduleService_ListScheduleServer interface {
	Send(*Schedule) error
	grpc.ServerStream
}

type UnimplementedScheduleServiceServer 

type UnimplementedScheduleServiceServer struct {
}

UnimplementedScheduleServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedScheduleServiceServer) CancelSchedule 

func (*UnimplementedScheduleServiceServer) CancelSchedule(ctx context.Context, req *Schedule) (*Schedule, error)

func (*UnimplementedScheduleServiceServer) CreateBrokerSchedule 

func (*UnimplementedScheduleServiceServer) CreateBrokerSchedule(ctx context.Context, req *CreateBrokerScheduleRequest) (*Schedule, error)

func (*UnimplementedScheduleServiceServer) CreateGrpcSchedule 

func (*UnimplementedScheduleServiceServer) CreateGrpcSchedule(ctx context.Context, req *CreateGrpcScheduleRequest) (*Schedule, error)

func (*UnimplementedScheduleServiceServer) CreateOneTimeBrokerSchedule 

func (*UnimplementedScheduleServiceServer) CreateOneTimeBrokerSchedule(ctx context.Context, req *CreateBrokerScheduleRequest) (*Schedule, error)

func (*UnimplementedScheduleServiceServer) CreateOneTimeGrpcSchedule 

func (*UnimplementedScheduleServiceServer) CreateOneTimeGrpcSchedule(ctx context.Context, req *CreateGrpcScheduleRequest) (*Schedule, error)

func (*UnimplementedScheduleServiceServer) ListSchedule 

func (*UnimplementedScheduleServiceServer) ListSchedule(req *ListScheduleRequest, srv ScheduleService_ListScheduleServer) error

func (*UnimplementedScheduleServiceServer) UpdateBrokerSchedule 

func (*UnimplementedScheduleServiceServer) UpdateBrokerSchedule(ctx context.Context, req *UpdateBrokerScheduleRequest) (*Schedule, error)

func (*UnimplementedScheduleServiceServer) UpdateGrpcSchedule 

func (*UnimplementedScheduleServiceServer) UpdateGrpcSchedule(ctx context.Context, req *UpdateGrpcScheduleRequest) (*Schedule, error)

type UpdateBrokerScheduleRequest 

type UpdateBrokerScheduleRequest struct {
	Period               string       `protobuf:"bytes,1,opt,name=period,proto3" json:"period,omitempty"`
	Schedule             *Schedule    `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`
	BrokerEvent          *BrokerEvent `protobuf:"bytes,3,opt,name=brokerEvent,proto3" json:"brokerEvent,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*UpdateBrokerScheduleRequest) Descriptor 

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

func (*UpdateBrokerScheduleRequest) GetBrokerEvent 

func (m *UpdateBrokerScheduleRequest) GetBrokerEvent() *BrokerEvent

func (*UpdateBrokerScheduleRequest) GetPeriod 

func (m *UpdateBrokerScheduleRequest) GetPeriod() string

func (*UpdateBrokerScheduleRequest) GetSchedule 

func (m *UpdateBrokerScheduleRequest) GetSchedule() *Schedule

func (*UpdateBrokerScheduleRequest) ProtoMessage 

func (*UpdateBrokerScheduleRequest) ProtoMessage()

func (*UpdateBrokerScheduleRequest) Reset 

func (m *UpdateBrokerScheduleRequest) Reset()

func (*UpdateBrokerScheduleRequest) String 

func (m *UpdateBrokerScheduleRequest) String() string

func (*UpdateBrokerScheduleRequest) XXX_DiscardUnknown 

func (m *UpdateBrokerScheduleRequest) XXX_DiscardUnknown()

func (*UpdateBrokerScheduleRequest) XXX_Marshal 

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

func (*UpdateBrokerScheduleRequest) XXX_Merge 

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

func (*UpdateBrokerScheduleRequest) XXX_Size 

func (m *UpdateBrokerScheduleRequest) XXX_Size() int

func (*UpdateBrokerScheduleRequest) XXX_Unmarshal 

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

type UpdateGrpcScheduleRequest 

type UpdateGrpcScheduleRequest struct {
	Period               string    `protobuf:"bytes,1,opt,name=period,proto3" json:"period,omitempty"`
	Schedule             *Schedule `protobuf:"bytes,2,opt,name=schedule,proto3" json:"schedule,omitempty"`
	GrpcCall             *GrpcCall `protobuf:"bytes,3,opt,name=grpcCall,proto3" json:"grpcCall,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*UpdateGrpcScheduleRequest) Descriptor 

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

func (*UpdateGrpcScheduleRequest) GetGrpcCall 

func (m *UpdateGrpcScheduleRequest) GetGrpcCall() *GrpcCall

func (*UpdateGrpcScheduleRequest) GetPeriod 

func (m *UpdateGrpcScheduleRequest) GetPeriod() string

func (*UpdateGrpcScheduleRequest) GetSchedule 

func (m *UpdateGrpcScheduleRequest) GetSchedule() *Schedule

func (*UpdateGrpcScheduleRequest) ProtoMessage 

func (*UpdateGrpcScheduleRequest) ProtoMessage()

func (*UpdateGrpcScheduleRequest) Reset 

func (m *UpdateGrpcScheduleRequest) Reset()

func (*UpdateGrpcScheduleRequest) String 

func (m *UpdateGrpcScheduleRequest) String() string

func (*UpdateGrpcScheduleRequest) XXX_DiscardUnknown 

func (m *UpdateGrpcScheduleRequest) XXX_DiscardUnknown()

func (*UpdateGrpcScheduleRequest) XXX_Marshal 

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

func (*UpdateGrpcScheduleRequest) XXX_Merge 

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

func (*UpdateGrpcScheduleRequest) XXX_Size 

func (m *UpdateGrpcScheduleRequest) XXX_Size() int

func (*UpdateGrpcScheduleRequest) XXX_Unmarshal 

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