trigger

Documentation

Index

• Variables
• func RegisterTriggerNodeServer(s grpc.ServiceRegistrar, srv TriggerNodeServer)
• type DeleteItemTriggerRequest
  • func (*DeleteItemTriggerRequest) Descriptor() ([]byte, []int)
  • func (x *DeleteItemTriggerRequest) GetId() string
  • func (x *DeleteItemTriggerRequest) GetKeygroup() string
  • func (*DeleteItemTriggerRequest) ProtoMessage()
  • func (x *DeleteItemTriggerRequest) ProtoReflect() protoreflect.Message
  • func (x *DeleteItemTriggerRequest) Reset()
  • func (x *DeleteItemTriggerRequest) String() string
• type Empty
  • func (*Empty) Descriptor() ([]byte, []int)
  • func (*Empty) ProtoMessage()
  • func (x *Empty) ProtoReflect() protoreflect.Message
  • func (x *Empty) Reset()
  • func (x *Empty) String() string
• type PutItemTriggerRequest
  • func (*PutItemTriggerRequest) Descriptor() ([]byte, []int)
  • func (x *PutItemTriggerRequest) GetId() string
  • func (x *PutItemTriggerRequest) GetKeygroup() string
  • func (x *PutItemTriggerRequest) GetVal() string
  • func (*PutItemTriggerRequest) ProtoMessage()
  • func (x *PutItemTriggerRequest) ProtoReflect() protoreflect.Message
  • func (x *PutItemTriggerRequest) Reset()
  • func (x *PutItemTriggerRequest) String() string
• type TriggerNodeClient
  • func NewTriggerNodeClient(cc grpc.ClientConnInterface) TriggerNodeClient
• type TriggerNodeServer
• type UnimplementedTriggerNodeServer
  • func (UnimplementedTriggerNodeServer) DeleteItemTrigger(context.Context, *DeleteItemTriggerRequest) (*Empty, error)
  • func (UnimplementedTriggerNodeServer) PutItemTrigger(context.Context, *PutItemTriggerRequest) (*Empty, error)
• type UnsafeTriggerNodeServer

Variables

var File_trigger_proto protoreflect.FileDescriptor

var TriggerNode_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "mcc.fred.trigger.TriggerNode",
	HandlerType: (*TriggerNodeServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PutItemTrigger",
			Handler:    _TriggerNode_PutItemTrigger_Handler,
		},
		{
			MethodName: "DeleteItemTrigger",
			Handler:    _TriggerNode_DeleteItemTrigger_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "trigger.proto",
}

TriggerNode_ServiceDesc is the grpc.ServiceDesc for TriggerNode service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterTriggerNodeServer

func RegisterTriggerNodeServer(s grpc.ServiceRegistrar, srv TriggerNodeServer)

Types

type DeleteItemTriggerRequest

type DeleteItemTriggerRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteItemTriggerRequest) Descriptor

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

Deprecated: Use DeleteItemTriggerRequest.ProtoReflect.Descriptor instead.

func (*DeleteItemTriggerRequest) GetId

func (x *DeleteItemTriggerRequest) GetId() string

func (*DeleteItemTriggerRequest) GetKeygroup

func (x *DeleteItemTriggerRequest) GetKeygroup() string

func (*DeleteItemTriggerRequest) ProtoMessage

func (*DeleteItemTriggerRequest) ProtoMessage()

func (*DeleteItemTriggerRequest) ProtoReflect

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

func (*DeleteItemTriggerRequest) Reset

func (x *DeleteItemTriggerRequest) Reset()

func (*DeleteItemTriggerRequest) String

func (x *DeleteItemTriggerRequest) String() string

type Empty

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

func (*Empty) Descriptor

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect

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

func (*Empty) Reset

func (x *Empty) Reset()

func (*Empty) String

func (x *Empty) String() string

type PutItemTriggerRequest

type PutItemTriggerRequest struct {
	Keygroup string `protobuf:"bytes,1,opt,name=keygroup,proto3" json:"keygroup,omitempty"`
	Id       string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Val      string `protobuf:"bytes,3,opt,name=val,proto3" json:"val,omitempty"`
	// contains filtered or unexported fields
}

func (*PutItemTriggerRequest) Descriptor

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

Deprecated: Use PutItemTriggerRequest.ProtoReflect.Descriptor instead.

func (*PutItemTriggerRequest) GetId

func (x *PutItemTriggerRequest) GetId() string

func (*PutItemTriggerRequest) GetKeygroup

func (x *PutItemTriggerRequest) GetKeygroup() string

func (*PutItemTriggerRequest) GetVal

func (x *PutItemTriggerRequest) GetVal() string

func (*PutItemTriggerRequest) ProtoMessage

func (*PutItemTriggerRequest) ProtoMessage()

func (*PutItemTriggerRequest) ProtoReflect

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

func (*PutItemTriggerRequest) Reset

func (x *PutItemTriggerRequest) Reset()

func (*PutItemTriggerRequest) String

func (x *PutItemTriggerRequest) String() string

type TriggerNodeClient

type TriggerNodeClient interface {
	PutItemTrigger(ctx context.Context, in *PutItemTriggerRequest, opts ...grpc.CallOption) (*Empty, error)
	DeleteItemTrigger(ctx context.Context, in *DeleteItemTriggerRequest, opts ...grpc.CallOption) (*Empty, error)
}

TriggerNodeClient is the client API for TriggerNode service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewTriggerNodeClient

func NewTriggerNodeClient(cc grpc.ClientConnInterface) TriggerNodeClient

type TriggerNodeServer

type TriggerNodeServer interface {
	PutItemTrigger(context.Context, *PutItemTriggerRequest) (*Empty, error)
	DeleteItemTrigger(context.Context, *DeleteItemTriggerRequest) (*Empty, error)
}

TriggerNodeServer is the server API for TriggerNode service. All implementations should embed UnimplementedTriggerNodeServer for forward compatibility

type UnimplementedTriggerNodeServer

type UnimplementedTriggerNodeServer struct {
}

UnimplementedTriggerNodeServer should be embedded to have forward compatible implementations.

func (UnimplementedTriggerNodeServer) DeleteItemTrigger

func (UnimplementedTriggerNodeServer) DeleteItemTrigger(context.Context, *DeleteItemTriggerRequest) (*Empty, error)

func (UnimplementedTriggerNodeServer) PutItemTrigger

func (UnimplementedTriggerNodeServer) PutItemTrigger(context.Context, *PutItemTriggerRequest) (*Empty, error)

type UnsafeTriggerNodeServer

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

UnsafeTriggerNodeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TriggerNodeServer will result in compilation errors.