proto

Documentation

Index

• Variables
• func RegisterProjectionServiceServer(s grpc.ServiceRegistrar, srv ProjectionServiceServer)
• type ProjectionServiceClient
  • func NewProjectionServiceClient(cc grpc.ClientConnInterface) ProjectionServiceClient
• type ProjectionServiceServer
• type TriggerRequest
  • func (*TriggerRequest) Descriptor() ([]byte, []int)
  • func (x *TriggerRequest) GetReset_() bool
  • func (x *TriggerRequest) GetSchedule() string
  • func (*TriggerRequest) ProtoMessage()
  • func (x *TriggerRequest) ProtoReflect() protoreflect.Message
  • func (x *TriggerRequest) Reset()
  • func (x *TriggerRequest) String() string
• type TriggerResponse
  • func (*TriggerResponse) Descriptor() ([]byte, []int)
  • func (x *TriggerResponse) GetAccepted() bool
  • func (*TriggerResponse) ProtoMessage()
  • func (x *TriggerResponse) ProtoReflect() protoreflect.Message
  • func (x *TriggerResponse) Reset()
  • func (x *TriggerResponse) String() string
• type UnimplementedProjectionServiceServer
  • func (UnimplementedProjectionServiceServer) Trigger(context.Context, *TriggerRequest) (*TriggerResponse, error)
• type UnsafeProjectionServiceServer

Variables

var File_projection_proto protoreflect.FileDescriptor

var ProjectionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cli.projection.ProjectionService",
	HandlerType: (*ProjectionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Trigger",
			Handler:    _ProjectionService_Trigger_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "projection.proto",
}

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

Functions

func RegisterProjectionServiceServer

func RegisterProjectionServiceServer(s grpc.ServiceRegistrar, srv ProjectionServiceServer)

Types

type ProjectionServiceClient

type ProjectionServiceClient interface {
	Trigger(ctx context.Context, in *TriggerRequest, opts ...grpc.CallOption) (*TriggerResponse, error)
}

ProjectionServiceClient is the client API for ProjectionService 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 NewProjectionServiceClient

func NewProjectionServiceClient(cc grpc.ClientConnInterface) ProjectionServiceClient

type ProjectionServiceServer

type ProjectionServiceServer interface {
	Trigger(context.Context, *TriggerRequest) (*TriggerResponse, error)
	// contains filtered or unexported methods
}

ProjectionServiceServer is the server API for ProjectionService service. All implementations must embed UnimplementedProjectionServiceServer for forward compatibility

type TriggerRequest

type TriggerRequest struct {
	Schedule string `protobuf:"bytes,1,opt,name=schedule,proto3" json:"schedule,omitempty"`
	Reset_   bool   `protobuf:"varint,2,opt,name=reset,proto3" json:"reset,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerRequest) Descriptor

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

Deprecated: Use TriggerRequest.ProtoReflect.Descriptor instead.

func (*TriggerRequest) GetReset_

func (x *TriggerRequest) GetReset_() bool

func (*TriggerRequest) GetSchedule

func (x *TriggerRequest) GetSchedule() string

func (*TriggerRequest) ProtoMessage

func (*TriggerRequest) ProtoMessage()

func (*TriggerRequest) ProtoReflect

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

func (*TriggerRequest) Reset

func (x *TriggerRequest) Reset()

func (*TriggerRequest) String

func (x *TriggerRequest) String() string

type TriggerResponse

type TriggerResponse struct {
	Accepted bool `protobuf:"varint,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerResponse) Descriptor

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

Deprecated: Use TriggerResponse.ProtoReflect.Descriptor instead.

func (*TriggerResponse) GetAccepted

func (x *TriggerResponse) GetAccepted() bool

func (*TriggerResponse) ProtoMessage

func (*TriggerResponse) ProtoMessage()

func (*TriggerResponse) ProtoReflect

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

func (*TriggerResponse) Reset

func (x *TriggerResponse) Reset()

func (*TriggerResponse) String

func (x *TriggerResponse) String() string

type UnimplementedProjectionServiceServer

type UnimplementedProjectionServiceServer struct {
}

UnimplementedProjectionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProjectionServiceServer) Trigger

func (UnimplementedProjectionServiceServer) Trigger(context.Context, *TriggerRequest) (*TriggerResponse, error)

type UnsafeProjectionServiceServer

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

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