projectionpb

Documentation

Index

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

Variables

var File_goes_projection_service_proto protoreflect.FileDescriptor

File_goes_projection_service_proto defines the protocol buffer messages TriggerReq and TriggerResp, used for the ProjectionService's Trigger method. The TriggerReq message contains a schedule string and a reset boolean, while the TriggerResp message contains an accepted boolean.

var ProjectionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "goes.projection.ProjectionService",
	HandlerType: (*ProjectionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Trigger",
			Handler:    _ProjectionService_Trigger_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "goes/projection/service.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)

RegisterProjectionServiceServer registers a ProjectionServiceServer implementation with the given grpc.ServiceRegistrar.

Types

type ProjectionServiceClient

type ProjectionServiceClient interface {
	Trigger(ctx context.Context, in *TriggerReq, opts ...grpc.CallOption) (*TriggerResp, 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

NewProjectionServiceClient creates a client stub for the ProjectionServiceClient. The client connects to the server specified by the grpc.ClientConnInterface parameter and can be used to call the Trigger RPC method on the ProjectionServiceServer.

type ProjectionServiceServer

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

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

type TriggerReq

type TriggerReq 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
}

TriggerReq represents a request to trigger a projection. It contains two fields: Schedule, which is a string that specifies the schedule for the projection, and Reset_, which is a boolean that indicates whether the projection should be reset before being triggered.

func (*TriggerReq) Descriptor

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

Deprecated: Use TriggerReq.ProtoReflect.Descriptor instead.

func (*TriggerReq) GetReset_

func (x *TriggerReq) GetReset_() bool

GetReset_ returns a boolean value indicating whether the reset flag is set in a TriggerReq message.

func (*TriggerReq) GetSchedule

func (x *TriggerReq) GetSchedule() string

GetSchedule returns the schedule string of a TriggerReq message. It returns an empty string if the TriggerReq is nil.

func (*TriggerReq) ProtoMessage

func (*TriggerReq) ProtoMessage()

ProtoMessage is a method implemented by *TriggerReq that marks it as a protobuf message type. This method is used to identify a struct as a protobuf message and allows it to be encoded and decoded using the protobuf encoding format.

func (*TriggerReq) ProtoReflect

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

ProtoReflect returns the message's reflection interface. This method is used internally by the protocol buffer library and should not be called by users. protoreflect.Message

func (*TriggerReq) Reset

func (x *TriggerReq) Reset()

Reset resets the TriggerReq to its zero value. It sets Schedule to empty string and Reset_ to false. This method is automatically called by protobuf library when a TriggerReq object is created.

func (*TriggerReq) String

func (x *TriggerReq) String() string

String returns a string representation of the TriggerReq message. It is generated by the protoimpl library.

type TriggerResp

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

TriggerResp represents the response message of the Trigger RPC call in the ProjectionService. It contains a single field, Accepted, which is a boolean value indicating whether the projection was accepted or not.

func (*TriggerResp) Descriptor

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

Deprecated: Use TriggerResp.ProtoReflect.Descriptor instead.

func (*TriggerResp) GetAccepted

func (x *TriggerResp) GetAccepted() bool

GetAccepted returns a boolean value indicating whether the trigger request was accepted or not. It is a method of the TriggerResp struct.

func (*TriggerResp) ProtoMessage

func (*TriggerResp) ProtoMessage()

ProtoMessage is an interface implemented by both TriggerReq and TriggerResp.

func (*TriggerResp) ProtoReflect

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

ProtoReflect returns the message's reflection interface. This method is used internally by the protocol buffer library and should not be called directly by user code.

func (*TriggerResp) Reset

func (x *TriggerResp) Reset()

Reset resets the TriggerResp to its zero value. It sets the Accepted field to false.

func (*TriggerResp) String

func (x *TriggerResp) String() string

String returns a string representation of the TriggerResp message. The returned string is in protobuf text format.

type UnimplementedProjectionServiceServer

type UnimplementedProjectionServiceServer struct {
}

UnimplementedProjectionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedProjectionServiceServer) Trigger

func (UnimplementedProjectionServiceServer) Trigger(context.Context, *TriggerReq) (*TriggerResp, error)

Trigger is a method of the UnimplementedProjectionServiceServer type, which implements the ProjectionServiceServer interface. It returns a nil response and an error with the code codes.Unimplemented and the message "method Trigger not implemented".

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.