timer

package
v0.0.0-...-fb9dcfe Latest Latest
Warning

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

 Go to latest Published: Jun 23, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterTimerServer 

func RegisterTimerServer(s *grpc.Server, srv TimerServer)

Types

type CallbackAction 

type CallbackAction struct {
	Type                 string            `protobuf:"bytes,1,opt,name=Type,proto3" json:"Type,omitempty"`
	Method               string            `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	Uri                  string            `protobuf:"bytes,3,opt,name=uri,proto3" json:"uri,omitempty"`
	Headers              map[string]string `` /* 155-byte string literal not displayed */
	Payload              string            `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*CallbackAction) Descriptor 

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

func (*CallbackAction) GetHeaders 

func (m *CallbackAction) GetHeaders() map[string]string

func (*CallbackAction) GetMethod 

func (m *CallbackAction) GetMethod() string

func (*CallbackAction) GetPayload 

func (m *CallbackAction) GetPayload() string

func (*CallbackAction) GetType 

func (m *CallbackAction) GetType() string

func (*CallbackAction) GetUri 

func (m *CallbackAction) GetUri() string

func (*CallbackAction) ProtoMessage 

func (*CallbackAction) ProtoMessage()

func (*CallbackAction) Reset 

func (m *CallbackAction) Reset()

func (*CallbackAction) String 

func (m *CallbackAction) String() string

func (*CallbackAction) XXX_DiscardUnknown 

func (m *CallbackAction) XXX_DiscardUnknown()

func (*CallbackAction) XXX_Marshal 

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

func (*CallbackAction) XXX_Merge 

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

func (*CallbackAction) XXX_Size 

func (m *CallbackAction) XXX_Size() int

func (*CallbackAction) XXX_Unmarshal 

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

type CreateTimerReply 

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

func (*CreateTimerReply) Descriptor 

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

func (*CreateTimerReply) GetTimerID 

func (m *CreateTimerReply) GetTimerID() string

func (*CreateTimerReply) ProtoMessage 

func (*CreateTimerReply) ProtoMessage()

func (*CreateTimerReply) Reset 

func (m *CreateTimerReply) Reset()

func (*CreateTimerReply) String 

func (m *CreateTimerReply) String() string

func (*CreateTimerReply) XXX_DiscardUnknown 

func (m *CreateTimerReply) XXX_DiscardUnknown()

func (*CreateTimerReply) XXX_Marshal 

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

func (*CreateTimerReply) XXX_Merge 

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

func (*CreateTimerReply) XXX_Size 

func (m *CreateTimerReply) XXX_Size() int

func (*CreateTimerReply) XXX_Unmarshal 

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

type CreateTimerRequest 

type CreateTimerRequest struct {
	Mode                 *TimerMode      `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"`
	Payload              string          `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Callback             *CallbackAction `protobuf:"bytes,3,opt,name=callback,proto3" json:"callback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*CreateTimerRequest) Descriptor 

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

func (*CreateTimerRequest) GetCallback 

func (m *CreateTimerRequest) GetCallback() *CallbackAction

func (*CreateTimerRequest) GetMode 

func (m *CreateTimerRequest) GetMode() *TimerMode

func (*CreateTimerRequest) GetPayload 

func (m *CreateTimerRequest) GetPayload() string

func (*CreateTimerRequest) ProtoMessage 

func (*CreateTimerRequest) ProtoMessage()

func (*CreateTimerRequest) Reset 

func (m *CreateTimerRequest) Reset()

func (*CreateTimerRequest) String 

func (m *CreateTimerRequest) String() string

func (*CreateTimerRequest) XXX_DiscardUnknown 

func (m *CreateTimerRequest) XXX_DiscardUnknown()

func (*CreateTimerRequest) XXX_Marshal 

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

func (*CreateTimerRequest) XXX_Merge 

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

func (*CreateTimerRequest) XXX_Size 

func (m *CreateTimerRequest) XXX_Size() int

func (*CreateTimerRequest) XXX_Unmarshal 

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

type DeleteTimerReply 

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

func (*DeleteTimerReply) Descriptor 

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

func (*DeleteTimerReply) ProtoMessage 

func (*DeleteTimerReply) ProtoMessage()

func (*DeleteTimerReply) Reset 

func (m *DeleteTimerReply) Reset()

func (*DeleteTimerReply) String 

func (m *DeleteTimerReply) String() string

func (*DeleteTimerReply) XXX_DiscardUnknown 

func (m *DeleteTimerReply) XXX_DiscardUnknown()

func (*DeleteTimerReply) XXX_Marshal 

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

func (*DeleteTimerReply) XXX_Merge 

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

func (*DeleteTimerReply) XXX_Size 

func (m *DeleteTimerReply) XXX_Size() int

func (*DeleteTimerReply) XXX_Unmarshal 

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

type DeleteTimerRequest 

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

func (*DeleteTimerRequest) Descriptor 

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

func (*DeleteTimerRequest) GetTimerID 

func (m *DeleteTimerRequest) GetTimerID() string

func (*DeleteTimerRequest) ProtoMessage 

func (*DeleteTimerRequest) ProtoMessage()

func (*DeleteTimerRequest) Reset 

func (m *DeleteTimerRequest) Reset()

func (*DeleteTimerRequest) String 

func (m *DeleteTimerRequest) String() string

func (*DeleteTimerRequest) XXX_DiscardUnknown 

func (m *DeleteTimerRequest) XXX_DiscardUnknown()

func (*DeleteTimerRequest) XXX_Marshal 

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

func (*DeleteTimerRequest) XXX_Merge 

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

func (*DeleteTimerRequest) XXX_Size 

func (m *DeleteTimerRequest) XXX_Size() int

func (*DeleteTimerRequest) XXX_Unmarshal 

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

type TimerClient 

type TimerClient interface {
	CreateTimer(ctx context.Context, in *CreateTimerRequest, opts ...grpc.CallOption) (*CreateTimerReply, error)
	DeleteTimer(ctx context.Context, in *DeleteTimerRequest, opts ...grpc.CallOption) (*DeleteTimerReply, error)
}

TimerClient is the client API for Timer service.

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

func NewTimerClient 

func NewTimerClient(cc *grpc.ClientConn) TimerClient

type TimerCreation 

type TimerCreation struct {
	TimerID              string     `protobuf:"bytes,1,opt,name=timerID,proto3" json:"timerID,omitempty"`
	Timestamp            uint64     `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Info                 *TimerInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*TimerCreation) Descriptor 

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

func (*TimerCreation) GetInfo 

func (m *TimerCreation) GetInfo() *TimerInfo

func (*TimerCreation) GetTimerID 

func (m *TimerCreation) GetTimerID() string

func (*TimerCreation) GetTimestamp 

func (m *TimerCreation) GetTimestamp() uint64

func (*TimerCreation) ProtoMessage 

func (*TimerCreation) ProtoMessage()

func (*TimerCreation) Reset 

func (m *TimerCreation) Reset()

func (*TimerCreation) String 

func (m *TimerCreation) String() string

func (*TimerCreation) XXX_DiscardUnknown 

func (m *TimerCreation) XXX_DiscardUnknown()

func (*TimerCreation) XXX_Marshal 

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

func (*TimerCreation) XXX_Merge 

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

func (*TimerCreation) XXX_Size 

func (m *TimerCreation) XXX_Size() int

func (*TimerCreation) XXX_Unmarshal 

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

type TimerDeletion 

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

func (*TimerDeletion) Descriptor 

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

func (*TimerDeletion) GetTimerID 

func (m *TimerDeletion) GetTimerID() string

func (*TimerDeletion) ProtoMessage 

func (*TimerDeletion) ProtoMessage()

func (*TimerDeletion) Reset 

func (m *TimerDeletion) Reset()

func (*TimerDeletion) String 

func (m *TimerDeletion) String() string

func (*TimerDeletion) XXX_DiscardUnknown 

func (m *TimerDeletion) XXX_DiscardUnknown()

func (*TimerDeletion) XXX_Marshal 

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

func (*TimerDeletion) XXX_Merge 

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

func (*TimerDeletion) XXX_Size 

func (m *TimerDeletion) XXX_Size() int

func (*TimerDeletion) XXX_Unmarshal 

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

type TimerInfo 

type TimerInfo struct {
	Payload              string          `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	Callback             *CallbackAction `protobuf:"bytes,2,opt,name=callback,proto3" json:"callback,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*TimerInfo) Descriptor 

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

func (*TimerInfo) GetCallback 

func (m *TimerInfo) GetCallback() *CallbackAction

func (*TimerInfo) GetPayload 

func (m *TimerInfo) GetPayload() string

func (*TimerInfo) ProtoMessage 

func (*TimerInfo) ProtoMessage()

func (*TimerInfo) Reset 

func (m *TimerInfo) Reset()

func (*TimerInfo) String 

func (m *TimerInfo) String() string

func (*TimerInfo) XXX_DiscardUnknown 

func (m *TimerInfo) XXX_DiscardUnknown()

func (*TimerInfo) XXX_Marshal 

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

func (*TimerInfo) XXX_Merge 

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

func (*TimerInfo) XXX_Size 

func (m *TimerInfo) XXX_Size() int

func (*TimerInfo) XXX_Unmarshal 

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

type TimerMode 

type TimerMode struct {
	Mode                 string   `protobuf:"bytes,1,opt,name=mode,proto3" json:"mode,omitempty"`
	Interval             uint32   `protobuf:"varint,2,opt,name=interval,proto3" json:"interval,omitempty"`
	Timestamp            uint64   `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TimerMode) Descriptor 

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

func (*TimerMode) GetInterval 

func (m *TimerMode) GetInterval() uint32

func (*TimerMode) GetMode 

func (m *TimerMode) GetMode() string

func (*TimerMode) GetTimestamp 

func (m *TimerMode) GetTimestamp() uint64

func (*TimerMode) ProtoMessage 

func (*TimerMode) ProtoMessage()

func (*TimerMode) Reset 

func (m *TimerMode) Reset()

func (*TimerMode) String 

func (m *TimerMode) String() string

func (*TimerMode) XXX_DiscardUnknown 

func (m *TimerMode) XXX_DiscardUnknown()

func (*TimerMode) XXX_Marshal 

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

func (*TimerMode) XXX_Merge 

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

func (*TimerMode) XXX_Size 

func (m *TimerMode) XXX_Size() int

func (*TimerMode) XXX_Unmarshal 

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

type TimerServer 

type TimerServer interface {
	CreateTimer(context.Context, *CreateTimerRequest) (*CreateTimerReply, error)
	DeleteTimer(context.Context, *DeleteTimerRequest) (*DeleteTimerReply, error)
}

TimerServer is the server API for Timer service.

type TimerTriggerInfo 

type TimerTriggerInfo struct {
	TimerID              string     `protobuf:"bytes,1,opt,name=timerID,proto3" json:"timerID,omitempty"`
	Info                 *TimerInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*TimerTriggerInfo) Descriptor 

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

func (*TimerTriggerInfo) GetInfo 

func (m *TimerTriggerInfo) GetInfo() *TimerInfo

func (*TimerTriggerInfo) GetTimerID 

func (m *TimerTriggerInfo) GetTimerID() string

func (*TimerTriggerInfo) ProtoMessage 

func (*TimerTriggerInfo) ProtoMessage()

func (*TimerTriggerInfo) Reset 

func (m *TimerTriggerInfo) Reset()

func (*TimerTriggerInfo) String 

func (m *TimerTriggerInfo) String() string

func (*TimerTriggerInfo) XXX_DiscardUnknown 

func (m *TimerTriggerInfo) XXX_DiscardUnknown()

func (*TimerTriggerInfo) XXX_Marshal 

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

func (*TimerTriggerInfo) XXX_Merge 

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

func (*TimerTriggerInfo) XXX_Size 

func (m *TimerTriggerInfo) XXX_Size() int

func (*TimerTriggerInfo) XXX_Unmarshal 

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

type UnimplementedTimerServer 

type UnimplementedTimerServer struct {
}

UnimplementedTimerServer can be embedded to have forward compatible implementations.

func (*UnimplementedTimerServer) CreateTimer 

func (*UnimplementedTimerServer) CreateTimer(ctx context.Context, req *CreateTimerRequest) (*CreateTimerReply, error)

func (*UnimplementedTimerServer) DeleteTimer 

func (*UnimplementedTimerServer) DeleteTimer(ctx context.Context, req *DeleteTimerRequest) (*DeleteTimerReply, 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.