centrifuge

package
v1.0.16-herb-centrifug... Latest Latest
Warning

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

 Go to latest Published: Apr 13, 2024 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CentrifugePositionService_StoreStreamPosition_FullMethodName = "/pkg.proto.centrifuge.CentrifugePositionService/StoreStreamPosition"
	CentrifugePositionService_GetStreamPosition_FullMethodName   = "/pkg.proto.centrifuge.CentrifugePositionService/GetStreamPosition"
)

Variables

View Source 
var CentrifugePositionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pkg.proto.centrifuge.CentrifugePositionService",
	HandlerType: (*CentrifugePositionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StoreStreamPosition",
			Handler:    _CentrifugePositionService_StoreStreamPosition_Handler,
		},
		{
			MethodName: "GetStreamPosition",
			Handler:    _CentrifugePositionService_GetStreamPosition_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/proto/centrifuge/centrifuge.proto",
}

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

View Source 
var File_pkg_proto_centrifuge_centrifuge_proto protoreflect.FileDescriptor

Functions

func AddCentrifugePositionServiceServer 

func AddCentrifugePositionServiceServer(cb fluffy_dozm_di.ContainerBuilder, ctor any)

AddCentrifugePositionServiceServer adds the fluffycore aware grpc server

func AddCentrifugePositionServiceServerWithExternalRegistration 

func AddCentrifugePositionServiceServerWithExternalRegistration(cb fluffy_dozm_di.ContainerBuilder, ctor any, register func() endpoint.IEndpointRegistration)

AddCentrifugePositionServiceServerWithExternalRegistration adds the fluffycore aware grpc server and external registration service. Mainly used for grpc-gateway

func RegisterCentrifugePositionServiceServer 

func RegisterCentrifugePositionServiceServer(s grpc.ServiceRegistrar, srv CentrifugePositionServiceServer)

Types

type CentrifugePositionServiceClient 

type CentrifugePositionServiceClient interface {
	StoreStreamPosition(ctx context.Context, in *StoreStreamPositionRequest, opts ...grpc.CallOption) (*StoreStreamPositionResponse, error)
	GetStreamPosition(ctx context.Context, in *GetStreamPositionRequest, opts ...grpc.CallOption) (*GetStreamPositionResponse, error)
}

CentrifugePositionServiceClient is the client API for CentrifugePositionService 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 NewCentrifugePositionServiceClient 

func NewCentrifugePositionServiceClient(cc grpc.ClientConnInterface) CentrifugePositionServiceClient

type CentrifugePositionServiceFluffyCoreServer 

type CentrifugePositionServiceFluffyCoreServer struct {
	UnimplementedCentrifugePositionServiceServer
	UnimplementedFluffyCoreCentrifugePositionServiceServerEndpointRegistration
}

CentrifugePositionServiceFluffyCoreServer defines the grpc server truct

func (*CentrifugePositionServiceFluffyCoreServer) GetStreamPosition 

func (s *CentrifugePositionServiceFluffyCoreServer) GetStreamPosition(ctx context.Context, request *GetStreamPositionRequest) (*GetStreamPositionResponse, error)

GetStreamPosition...

func (*CentrifugePositionServiceFluffyCoreServer) RegisterFluffyCoreGRPCService 

func (srv *CentrifugePositionServiceFluffyCoreServer) RegisterFluffyCoreGRPCService(s *grpc.Server)

RegisterFluffyCoreGRPCService the server with grpc

func (*CentrifugePositionServiceFluffyCoreServer) StoreStreamPosition 

func (s *CentrifugePositionServiceFluffyCoreServer) StoreStreamPosition(ctx context.Context, request *StoreStreamPositionRequest) (*StoreStreamPositionResponse, error)

StoreStreamPosition...

type CentrifugePositionServiceServer 

type CentrifugePositionServiceServer interface {
	StoreStreamPosition(context.Context, *StoreStreamPositionRequest) (*StoreStreamPositionResponse, error)
	GetStreamPosition(context.Context, *GetStreamPositionRequest) (*GetStreamPositionResponse, error)
	// contains filtered or unexported methods
}

CentrifugePositionServiceServer is the server API for CentrifugePositionService service. All implementations must embed UnimplementedCentrifugePositionServiceServer for forward compatibility

type GetStreamPositionRequest 

type GetStreamPositionRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamPositionRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamPositionRequest.ProtoReflect.Descriptor instead.

func (*GetStreamPositionRequest) GetChannel 

func (x *GetStreamPositionRequest) GetChannel() string

func (*GetStreamPositionRequest) ProtoMessage 

func (*GetStreamPositionRequest) ProtoMessage()

func (*GetStreamPositionRequest) ProtoReflect 

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

func (*GetStreamPositionRequest) Reset 

func (x *GetStreamPositionRequest) Reset()

func (*GetStreamPositionRequest) String 

func (x *GetStreamPositionRequest) String() string

type GetStreamPositionResponse 

type GetStreamPositionResponse struct {
	StreamPosition *StreamPosition `protobuf:"bytes,1,opt,name=stream_position,json=streamPosition,proto3" json:"stream_position,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamPositionResponse) Descriptor deprecated 

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

Deprecated: Use GetStreamPositionResponse.ProtoReflect.Descriptor instead.

func (*GetStreamPositionResponse) GetStreamPosition 

func (x *GetStreamPositionResponse) GetStreamPosition() *StreamPosition

func (*GetStreamPositionResponse) ProtoMessage 

func (*GetStreamPositionResponse) ProtoMessage()

func (*GetStreamPositionResponse) ProtoReflect 

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

func (*GetStreamPositionResponse) Reset 

func (x *GetStreamPositionResponse) Reset()

func (*GetStreamPositionResponse) String 

func (x *GetStreamPositionResponse) String() string

type IFluffyCoreCentrifugePositionServiceServer 

type IFluffyCoreCentrifugePositionServiceServer interface {
	CentrifugePositionServiceServer
}

IFluffyCoreCentrifugePositionServiceServer defines the grpc server

type StoreStreamPositionRequest 

type StoreStreamPositionRequest struct {
	StreamPosition *StreamPosition `protobuf:"bytes,2,opt,name=stream_position,json=streamPosition,proto3" json:"stream_position,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreStreamPositionRequest) Descriptor deprecated 

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

Deprecated: Use StoreStreamPositionRequest.ProtoReflect.Descriptor instead.

func (*StoreStreamPositionRequest) GetStreamPosition 

func (x *StoreStreamPositionRequest) GetStreamPosition() *StreamPosition

func (*StoreStreamPositionRequest) ProtoMessage 

func (*StoreStreamPositionRequest) ProtoMessage()

func (*StoreStreamPositionRequest) ProtoReflect 

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

func (*StoreStreamPositionRequest) Reset 

func (x *StoreStreamPositionRequest) Reset()

func (*StoreStreamPositionRequest) String 

func (x *StoreStreamPositionRequest) String() string

type StoreStreamPositionResponse 

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

func (*StoreStreamPositionResponse) Descriptor deprecated 

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

Deprecated: Use StoreStreamPositionResponse.ProtoReflect.Descriptor instead.

func (*StoreStreamPositionResponse) ProtoMessage 

func (*StoreStreamPositionResponse) ProtoMessage()

func (*StoreStreamPositionResponse) ProtoReflect 

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

func (*StoreStreamPositionResponse) Reset 

func (x *StoreStreamPositionResponse) Reset()

func (*StoreStreamPositionResponse) String 

func (x *StoreStreamPositionResponse) String() string

type StreamPosition 

type StreamPosition struct {
	Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	Offset  uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Epoch   string `protobuf:"bytes,4,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPosition) Descriptor deprecated 

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

Deprecated: Use StreamPosition.ProtoReflect.Descriptor instead.

func (*StreamPosition) GetChannel 

func (x *StreamPosition) GetChannel() string

func (*StreamPosition) GetEpoch 

func (x *StreamPosition) GetEpoch() string

func (*StreamPosition) GetOffset 

func (x *StreamPosition) GetOffset() uint64

func (*StreamPosition) ProtoMessage 

func (*StreamPosition) ProtoMessage()

func (*StreamPosition) ProtoReflect 

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

func (*StreamPosition) Reset 

func (x *StreamPosition) Reset()

func (*StreamPosition) String 

func (x *StreamPosition) String() string

type StreamPositionDto 

type StreamPositionDto struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Channel   string                 `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	Offset    uint64                 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Epoch     string                 `protobuf:"bytes,4,opt,name=epoch,proto3" json:"epoch,omitempty"`
	UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,21,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPositionDto) Descriptor deprecated 

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

Deprecated: Use StreamPositionDto.ProtoReflect.Descriptor instead.

func (*StreamPositionDto) GetChannel 

func (x *StreamPositionDto) GetChannel() string

func (*StreamPositionDto) GetEpoch 

func (x *StreamPositionDto) GetEpoch() string

func (*StreamPositionDto) GetId 

func (x *StreamPositionDto) GetId() string

func (*StreamPositionDto) GetOffset 

func (x *StreamPositionDto) GetOffset() uint64

func (*StreamPositionDto) GetUpdatedAt 

func (x *StreamPositionDto) GetUpdatedAt() *timestamppb.Timestamp

func (*StreamPositionDto) ProtoMessage 

func (*StreamPositionDto) ProtoMessage()

func (*StreamPositionDto) ProtoReflect 

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

func (*StreamPositionDto) Reset 

func (x *StreamPositionDto) Reset()

func (*StreamPositionDto) String 

func (x *StreamPositionDto) String() string

type UnimplementedCentrifugePositionServiceServer 

type UnimplementedCentrifugePositionServiceServer struct {
}

UnimplementedCentrifugePositionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCentrifugePositionServiceServer) GetStreamPosition 

func (UnimplementedCentrifugePositionServiceServer) GetStreamPosition(context.Context, *GetStreamPositionRequest) (*GetStreamPositionResponse, error)

func (UnimplementedCentrifugePositionServiceServer) StoreStreamPosition 

func (UnimplementedCentrifugePositionServiceServer) StoreStreamPosition(context.Context, *StoreStreamPositionRequest) (*StoreStreamPositionResponse, error)

type UnimplementedFluffyCoreCentrifugePositionServiceServerEndpointRegistration 

type UnimplementedFluffyCoreCentrifugePositionServiceServerEndpointRegistration struct {
}

func (UnimplementedFluffyCoreCentrifugePositionServiceServerEndpointRegistration) RegisterFluffyCoreHandler 

func (UnimplementedFluffyCoreCentrifugePositionServiceServerEndpointRegistration) RegisterFluffyCoreHandler(gwmux *runtime.ServeMux, conn *grpc.ClientConn)

type UnsafeCentrifugePositionServiceServer 

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

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

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.