trigger

Documentation

Index

• Constants
• Variables
• func NewTriggerServiceEndpoints() []*api.Endpoint
• func RegisterTriggerServiceHandler(s server.Server, hdlr TriggerServiceHandler, opts ...server.HandlerOption) error
• type CreateTriggerRequest
  • func (*CreateTriggerRequest) Descriptor() ([]byte, []int)
  • func (x *CreateTriggerRequest) GetTrigger() *Trigger
  • func (*CreateTriggerRequest) ProtoMessage()
  • func (x *CreateTriggerRequest) ProtoReflect() protoreflect.Message
  • func (x *CreateTriggerRequest) Reset()
  • func (x *CreateTriggerRequest) String() string
• type GetTriggersRequest
  • func (*GetTriggersRequest) Descriptor() ([]byte, []int)
  • func (x *GetTriggersRequest) GetLimit() int64
  • func (x *GetTriggersRequest) GetOffset() int64
  • func (*GetTriggersRequest) ProtoMessage()
  • func (x *GetTriggersRequest) ProtoReflect() protoreflect.Message
  • func (x *GetTriggersRequest) Reset()
  • func (x *GetTriggersRequest) String() string
• type GetTriggersResponse
  • func (*GetTriggersResponse) Descriptor() ([]byte, []int)
  • func (x *GetTriggersResponse) GetCount() int64
  • func (x *GetTriggersResponse) GetTriggers() []*Trigger
  • func (*GetTriggersResponse) ProtoMessage()
  • func (x *GetTriggersResponse) ProtoReflect() protoreflect.Message
  • func (x *GetTriggersResponse) Reset()
  • func (x *GetTriggersResponse) String() string
• type Trigger
  • func (*Trigger) Descriptor() ([]byte, []int)
  • func (x *Trigger) GetSpec() string
  • func (x *Trigger) GetTriggerId() int64
  • func (*Trigger) ProtoMessage()
  • func (x *Trigger) ProtoReflect() protoreflect.Message
  • func (x *Trigger) Reset()
  • func (x *Trigger) String() string
• type TriggerService
  • func NewTriggerService(name string, c client.Client) TriggerService
• type TriggerServiceHandler

Constants

const (
	ServiceName = "trigger"
)

Variables

var File_trigger_trigger_proto protoreflect.FileDescriptor

Functions

func NewTriggerServiceEndpoints

func NewTriggerServiceEndpoints() []*api.Endpoint

func RegisterTriggerServiceHandler

func RegisterTriggerServiceHandler(s server.Server, hdlr TriggerServiceHandler, opts ...server.HandlerOption) error

Types

type CreateTriggerRequest

type CreateTriggerRequest struct {
	Trigger *Trigger `protobuf:"bytes,1,opt,name=trigger,proto3" json:"trigger,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTriggerRequest) Descriptor

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

Deprecated: Use CreateTriggerRequest.ProtoReflect.Descriptor instead.

func (*CreateTriggerRequest) GetTrigger

func (x *CreateTriggerRequest) GetTrigger() *Trigger

func (*CreateTriggerRequest) ProtoMessage

func (*CreateTriggerRequest) ProtoMessage()

func (*CreateTriggerRequest) ProtoReflect

func (x *CreateTriggerRequest) ProtoReflect() protoreflect.Message

func (*CreateTriggerRequest) Reset

func (x *CreateTriggerRequest) Reset()

func (*CreateTriggerRequest) String

func (x *CreateTriggerRequest) String() string

type GetTriggersRequest

type GetTriggersRequest struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit  int64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTriggersRequest) Descriptor

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

Deprecated: Use GetTriggersRequest.ProtoReflect.Descriptor instead.

func (*GetTriggersRequest) GetLimit

func (x *GetTriggersRequest) GetLimit() int64

func (*GetTriggersRequest) GetOffset

func (x *GetTriggersRequest) GetOffset() int64

func (*GetTriggersRequest) ProtoMessage

func (*GetTriggersRequest) ProtoMessage()

func (*GetTriggersRequest) ProtoReflect

func (x *GetTriggersRequest) ProtoReflect() protoreflect.Message

func (*GetTriggersRequest) Reset

func (x *GetTriggersRequest) Reset()

func (*GetTriggersRequest) String

func (x *GetTriggersRequest) String() string

type GetTriggersResponse

type GetTriggersResponse struct {
	Count    int64      `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	Triggers []*Trigger `protobuf:"bytes,2,rep,name=triggers,proto3" json:"triggers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTriggersResponse) Descriptor

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

Deprecated: Use GetTriggersResponse.ProtoReflect.Descriptor instead.

func (*GetTriggersResponse) GetCount

func (x *GetTriggersResponse) GetCount() int64

func (*GetTriggersResponse) GetTriggers

func (x *GetTriggersResponse) GetTriggers() []*Trigger

func (*GetTriggersResponse) ProtoMessage

func (*GetTriggersResponse) ProtoMessage()

func (*GetTriggersResponse) ProtoReflect

func (x *GetTriggersResponse) ProtoReflect() protoreflect.Message

func (*GetTriggersResponse) Reset

func (x *GetTriggersResponse) Reset()

func (*GetTriggersResponse) String

func (x *GetTriggersResponse) String() string

type Trigger

type Trigger struct {
	TriggerId int64  `protobuf:"varint,1,opt,name=trigger_id,json=triggerId,proto3" json:"trigger_id,omitempty"`
	Spec      string `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// contains filtered or unexported fields
}

func (*Trigger) Descriptor

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

Deprecated: Use Trigger.ProtoReflect.Descriptor instead.

func (*Trigger) GetSpec

func (x *Trigger) GetSpec() string

func (*Trigger) GetTriggerId

func (x *Trigger) GetTriggerId() int64

func (*Trigger) ProtoMessage

func (*Trigger) ProtoMessage()

func (*Trigger) ProtoReflect

func (x *Trigger) ProtoReflect() protoreflect.Message

func (*Trigger) Reset

func (x *Trigger) Reset()

func (*Trigger) String

func (x *Trigger) String() string

type TriggerService

type TriggerService interface {
	CreateTrigger(ctx context.Context, in *CreateTriggerRequest, opts ...client.CallOption) (*emptypb.Empty, error)
	GetTriggers(ctx context.Context, in *GetTriggersRequest, opts ...client.CallOption) (*GetTriggersResponse, error)
}

func NewTriggerService

func NewTriggerService(name string, c client.Client) TriggerService

type TriggerServiceHandler

type TriggerServiceHandler interface {
	CreateTrigger(context.Context, *CreateTriggerRequest, *emptypb.Empty) error
	GetTriggers(context.Context, *GetTriggersRequest, *GetTriggersResponse) error
}