servicev1

package
v0.0.5 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 2025 License: MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PushService_Push_FullMethodName      = "/gate.service.push.v1.PushService/Push"
	PushService_Multicast_FullMethodName = "/gate.service.push.v1.PushService/Multicast"
	PushService_Broadcast_FullMethodName = "/gate.service.push.v1.PushService/Broadcast"
)
View Source 
const OperationPushServiceBroadcast = "/gate.service.push.v1.PushService/Broadcast"
View Source 
const OperationPushServiceMulticast = "/gate.service.push.v1.PushService/Multicast"
View Source 
const OperationPushServicePush = "/gate.service.push.v1.PushService/Push"

Variables

View Source 
var (
	PushServiceErrorReason_name = map[int32]string{
		0: "PUSH_SERVICE_ERROR_REASON_UNSPECIFIED",
		1: "PUSH_SERVICE_ERROR_REASON_SERVER",
		2: "PUSH_SERVICE_ERROR_REASON_SERVER_ID",
	}
	PushServiceErrorReason_value = map[string]int32{
		"PUSH_SERVICE_ERROR_REASON_UNSPECIFIED": 0,
		"PUSH_SERVICE_ERROR_REASON_SERVER":      1,
		"PUSH_SERVICE_ERROR_REASON_SERVER_ID":   2,
	}
)

Enum value maps for PushServiceErrorReason.

View Source 
var File_gate_service_push_v1_push_error_proto protoreflect.FileDescriptor
View Source 
var File_gate_service_push_v1_push_proto protoreflect.FileDescriptor
View Source 
var PushService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gate.service.push.v1.PushService",
	HandlerType: (*PushServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Push",
			Handler:    _PushService_Push_Handler,
		},
		{
			MethodName: "Multicast",
			Handler:    _PushService_Multicast_Handler,
		},
		{
			MethodName: "Broadcast",
			Handler:    _PushService_Broadcast_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gate/service/push/v1/push.proto",
}

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

Functions

func ErrorPushServiceErrorReasonServer 

func ErrorPushServiceErrorReasonServer(format string, args ...interface{}) *errors.Error

func ErrorPushServiceErrorReasonServerId 

func ErrorPushServiceErrorReasonServerId(format string, args ...interface{}) *errors.Error

func ErrorPushServiceErrorReasonUnspecified 

func ErrorPushServiceErrorReasonUnspecified(format string, args ...interface{}) *errors.Error

func IsPushServiceErrorReasonServer 

func IsPushServiceErrorReasonServer(err error) bool

func IsPushServiceErrorReasonServerId 

func IsPushServiceErrorReasonServerId(err error) bool

func IsPushServiceErrorReasonUnspecified 

func IsPushServiceErrorReasonUnspecified(err error) bool

func RegisterPushServiceHTTPServer 

func RegisterPushServiceHTTPServer(s *http.Server, srv PushServiceHTTPServer)

func RegisterPushServiceServer 

func RegisterPushServiceServer(s grpc.ServiceRegistrar, srv PushServiceServer)

Types

type BroadcastRequest 

type BroadcastRequest struct {
	Bodies []*PushBody `protobuf:"bytes,1,rep,name=bodies,proto3" json:"bodies,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastRequest) Descriptor deprecated 

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

Deprecated: Use BroadcastRequest.ProtoReflect.Descriptor instead.

func (*BroadcastRequest) GetBodies 

func (x *BroadcastRequest) GetBodies() []*PushBody

func (*BroadcastRequest) ProtoMessage 

func (*BroadcastRequest) ProtoMessage()

func (*BroadcastRequest) ProtoReflect 

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

func (*BroadcastRequest) Reset 

func (x *BroadcastRequest) Reset()

func (*BroadcastRequest) String 

func (x *BroadcastRequest) String() string

func (*BroadcastRequest) Validate 

func (m *BroadcastRequest) Validate() error

Validate checks the field values on BroadcastRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*BroadcastRequest) ValidateAll 

func (m *BroadcastRequest) ValidateAll() error

ValidateAll checks the field values on BroadcastRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in BroadcastRequestMultiError, or nil if none found.

type BroadcastRequestMultiError 

type BroadcastRequestMultiError []error

BroadcastRequestMultiError is an error wrapping multiple validation errors returned by BroadcastRequest.ValidateAll() if the designated constraints aren't met.

func (BroadcastRequestMultiError) AllErrors 

func (m BroadcastRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BroadcastRequestMultiError) Error 

func (m BroadcastRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type BroadcastRequestValidationError 

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

BroadcastRequestValidationError is the validation error returned by BroadcastRequest.Validate if the designated constraints aren't met.

func (BroadcastRequestValidationError) Cause 

func (e BroadcastRequestValidationError) Cause() error

Cause function returns cause value.

func (BroadcastRequestValidationError) Error 

func (e BroadcastRequestValidationError) Error() string

Error satisfies the builtin error interface

func (BroadcastRequestValidationError) ErrorName 

func (e BroadcastRequestValidationError) ErrorName() string

ErrorName returns error name.

func (BroadcastRequestValidationError) Field 

func (e BroadcastRequestValidationError) Field() string

Field function returns field value.

func (BroadcastRequestValidationError) Key 

func (e BroadcastRequestValidationError) Key() bool

Key function returns key value.

func (BroadcastRequestValidationError) Reason 

func (e BroadcastRequestValidationError) Reason() string

Reason function returns reason value.

type BroadcastResponse 

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

func (*BroadcastResponse) Descriptor deprecated 

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

Deprecated: Use BroadcastResponse.ProtoReflect.Descriptor instead.

func (*BroadcastResponse) ProtoMessage 

func (*BroadcastResponse) ProtoMessage()

func (*BroadcastResponse) ProtoReflect 

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

func (*BroadcastResponse) Reset 

func (x *BroadcastResponse) Reset()

func (*BroadcastResponse) String 

func (x *BroadcastResponse) String() string

func (*BroadcastResponse) Validate 

func (m *BroadcastResponse) Validate() error

Validate checks the field values on BroadcastResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*BroadcastResponse) ValidateAll 

func (m *BroadcastResponse) ValidateAll() error

ValidateAll checks the field values on BroadcastResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in BroadcastResponseMultiError, or nil if none found.

type BroadcastResponseMultiError 

type BroadcastResponseMultiError []error

BroadcastResponseMultiError is an error wrapping multiple validation errors returned by BroadcastResponse.ValidateAll() if the designated constraints aren't met.

func (BroadcastResponseMultiError) AllErrors 

func (m BroadcastResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (BroadcastResponseMultiError) Error 

func (m BroadcastResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type BroadcastResponseValidationError 

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

BroadcastResponseValidationError is the validation error returned by BroadcastResponse.Validate if the designated constraints aren't met.

func (BroadcastResponseValidationError) Cause 

func (e BroadcastResponseValidationError) Cause() error

Cause function returns cause value.

func (BroadcastResponseValidationError) Error 

func (e BroadcastResponseValidationError) Error() string

Error satisfies the builtin error interface

func (BroadcastResponseValidationError) ErrorName 

func (e BroadcastResponseValidationError) ErrorName() string

ErrorName returns error name.

func (BroadcastResponseValidationError) Field 

func (e BroadcastResponseValidationError) Field() string

Field function returns field value.

func (BroadcastResponseValidationError) Key 

func (e BroadcastResponseValidationError) Key() bool

Key function returns key value.

func (BroadcastResponseValidationError) Reason 

func (e BroadcastResponseValidationError) Reason() string

Reason function returns reason value.

type MulticastRequest 

type MulticastRequest struct {
	Uid    []int64     `protobuf:"varint,1,rep,packed,name=uid,proto3" json:"uid,omitempty"`
	Bodies []*PushBody `protobuf:"bytes,2,rep,name=bodies,proto3" json:"bodies,omitempty"`
	// contains filtered or unexported fields
}

func (*MulticastRequest) Descriptor deprecated 

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

Deprecated: Use MulticastRequest.ProtoReflect.Descriptor instead.

func (*MulticastRequest) GetBodies 

func (x *MulticastRequest) GetBodies() []*PushBody

func (*MulticastRequest) GetUid 

func (x *MulticastRequest) GetUid() []int64

func (*MulticastRequest) ProtoMessage 

func (*MulticastRequest) ProtoMessage()

func (*MulticastRequest) ProtoReflect 

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

func (*MulticastRequest) Reset 

func (x *MulticastRequest) Reset()

func (*MulticastRequest) String 

func (x *MulticastRequest) String() string

func (*MulticastRequest) Validate 

func (m *MulticastRequest) Validate() error

Validate checks the field values on MulticastRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*MulticastRequest) ValidateAll 

func (m *MulticastRequest) ValidateAll() error

ValidateAll checks the field values on MulticastRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in MulticastRequestMultiError, or nil if none found.

type MulticastRequestMultiError 

type MulticastRequestMultiError []error

MulticastRequestMultiError is an error wrapping multiple validation errors returned by MulticastRequest.ValidateAll() if the designated constraints aren't met.

func (MulticastRequestMultiError) AllErrors 

func (m MulticastRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (MulticastRequestMultiError) Error 

func (m MulticastRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type MulticastRequestValidationError 

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

MulticastRequestValidationError is the validation error returned by MulticastRequest.Validate if the designated constraints aren't met.

func (MulticastRequestValidationError) Cause 

func (e MulticastRequestValidationError) Cause() error

Cause function returns cause value.

func (MulticastRequestValidationError) Error 

func (e MulticastRequestValidationError) Error() string

Error satisfies the builtin error interface

func (MulticastRequestValidationError) ErrorName 

func (e MulticastRequestValidationError) ErrorName() string

ErrorName returns error name.

func (MulticastRequestValidationError) Field 

func (e MulticastRequestValidationError) Field() string

Field function returns field value.

func (MulticastRequestValidationError) Key 

func (e MulticastRequestValidationError) Key() bool

Key function returns key value.

func (MulticastRequestValidationError) Reason 

func (e MulticastRequestValidationError) Reason() string

Reason function returns reason value.

type MulticastResponse 

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

func (*MulticastResponse) Descriptor deprecated 

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

Deprecated: Use MulticastResponse.ProtoReflect.Descriptor instead.

func (*MulticastResponse) ProtoMessage 

func (*MulticastResponse) ProtoMessage()

func (*MulticastResponse) ProtoReflect 

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

func (*MulticastResponse) Reset 

func (x *MulticastResponse) Reset()

func (*MulticastResponse) String 

func (x *MulticastResponse) String() string

func (*MulticastResponse) Validate 

func (m *MulticastResponse) Validate() error

Validate checks the field values on MulticastResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*MulticastResponse) ValidateAll 

func (m *MulticastResponse) ValidateAll() error

ValidateAll checks the field values on MulticastResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in MulticastResponseMultiError, or nil if none found.

type MulticastResponseMultiError 

type MulticastResponseMultiError []error

MulticastResponseMultiError is an error wrapping multiple validation errors returned by MulticastResponse.ValidateAll() if the designated constraints aren't met.

func (MulticastResponseMultiError) AllErrors 

func (m MulticastResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (MulticastResponseMultiError) Error 

func (m MulticastResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type MulticastResponseValidationError 

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

MulticastResponseValidationError is the validation error returned by MulticastResponse.Validate if the designated constraints aren't met.

func (MulticastResponseValidationError) Cause 

func (e MulticastResponseValidationError) Cause() error

Cause function returns cause value.

func (MulticastResponseValidationError) Error 

func (e MulticastResponseValidationError) Error() string

Error satisfies the builtin error interface

func (MulticastResponseValidationError) ErrorName 

func (e MulticastResponseValidationError) ErrorName() string

ErrorName returns error name.

func (MulticastResponseValidationError) Field 

func (e MulticastResponseValidationError) Field() string

Field function returns field value.

func (MulticastResponseValidationError) Key 

func (e MulticastResponseValidationError) Key() bool

Key function returns key value.

func (MulticastResponseValidationError) Reason 

func (e MulticastResponseValidationError) Reason() string

Reason function returns reason value.

type PushBody 

type PushBody struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // Message body proto bytes array
	Obj  int64  `protobuf:"varint,2,opt,name=obj,proto3" json:"obj,omitempty"`  // Object ID, according to the business agreement
	Mod  int32  `protobuf:"varint,3,opt,name=mod,proto3" json:"mod,omitempty"`  // Module ID, globally unique
	Seq  int32  `protobuf:"varint,4,opt,name=seq,proto3" json:"seq,omitempty"`  // Message ID within the module, unique within the module
	// contains filtered or unexported fields
}

func (*PushBody) Descriptor deprecated 

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

Deprecated: Use PushBody.ProtoReflect.Descriptor instead.

func (*PushBody) GetData 

func (x *PushBody) GetData() []byte

func (*PushBody) GetMod 

func (x *PushBody) GetMod() int32

func (*PushBody) GetObj 

func (x *PushBody) GetObj() int64

func (*PushBody) GetSeq 

func (x *PushBody) GetSeq() int32

func (*PushBody) ProtoMessage 

func (*PushBody) ProtoMessage()

func (*PushBody) ProtoReflect 

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

func (*PushBody) Reset 

func (x *PushBody) Reset()

func (*PushBody) String 

func (x *PushBody) String() string

func (*PushBody) Validate 

func (m *PushBody) Validate() error

Validate checks the field values on PushBody with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PushBody) ValidateAll 

func (m *PushBody) ValidateAll() error

ValidateAll checks the field values on PushBody with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PushBodyMultiError, or nil if none found.

type PushBodyMultiError 

type PushBodyMultiError []error

PushBodyMultiError is an error wrapping multiple validation errors returned by PushBody.ValidateAll() if the designated constraints aren't met.

func (PushBodyMultiError) AllErrors 

func (m PushBodyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PushBodyMultiError) Error 

func (m PushBodyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PushBodyValidationError 

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

PushBodyValidationError is the validation error returned by PushBody.Validate if the designated constraints aren't met.

func (PushBodyValidationError) Cause 

func (e PushBodyValidationError) Cause() error

Cause function returns cause value.

func (PushBodyValidationError) Error 

func (e PushBodyValidationError) Error() string

Error satisfies the builtin error interface

func (PushBodyValidationError) ErrorName 

func (e PushBodyValidationError) ErrorName() string

ErrorName returns error name.

func (PushBodyValidationError) Field 

func (e PushBodyValidationError) Field() string

Field function returns field value.

func (PushBodyValidationError) Key 

func (e PushBodyValidationError) Key() bool

Key function returns key value.

func (PushBodyValidationError) Reason 

func (e PushBodyValidationError) Reason() string

Reason function returns reason value.

type PushRequest 

type PushRequest struct {
	Uid    int64       `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Bodies []*PushBody `protobuf:"bytes,2,rep,name=bodies,proto3" json:"bodies,omitempty"`
	// contains filtered or unexported fields
}

func (*PushRequest) Descriptor deprecated 

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

Deprecated: Use PushRequest.ProtoReflect.Descriptor instead.

func (*PushRequest) GetBodies 

func (x *PushRequest) GetBodies() []*PushBody

func (*PushRequest) GetUid 

func (x *PushRequest) GetUid() int64

func (*PushRequest) ProtoMessage 

func (*PushRequest) ProtoMessage()

func (*PushRequest) ProtoReflect 

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

func (*PushRequest) Reset 

func (x *PushRequest) Reset()

func (*PushRequest) String 

func (x *PushRequest) String() string

func (*PushRequest) Validate 

func (m *PushRequest) Validate() error

Validate checks the field values on PushRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PushRequest) ValidateAll 

func (m *PushRequest) ValidateAll() error

ValidateAll checks the field values on PushRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PushRequestMultiError, or nil if none found.

type PushRequestMultiError 

type PushRequestMultiError []error

PushRequestMultiError is an error wrapping multiple validation errors returned by PushRequest.ValidateAll() if the designated constraints aren't met.

func (PushRequestMultiError) AllErrors 

func (m PushRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PushRequestMultiError) Error 

func (m PushRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PushRequestValidationError 

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

PushRequestValidationError is the validation error returned by PushRequest.Validate if the designated constraints aren't met.

func (PushRequestValidationError) Cause 

func (e PushRequestValidationError) Cause() error

Cause function returns cause value.

func (PushRequestValidationError) Error 

func (e PushRequestValidationError) Error() string

Error satisfies the builtin error interface

func (PushRequestValidationError) ErrorName 

func (e PushRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PushRequestValidationError) Field 

func (e PushRequestValidationError) Field() string

Field function returns field value.

func (PushRequestValidationError) Key 

func (e PushRequestValidationError) Key() bool

Key function returns key value.

func (PushRequestValidationError) Reason 

func (e PushRequestValidationError) Reason() string

Reason function returns reason value.

type PushResponse 

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

func (*PushResponse) Descriptor deprecated 

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

Deprecated: Use PushResponse.ProtoReflect.Descriptor instead.

func (*PushResponse) ProtoMessage 

func (*PushResponse) ProtoMessage()

func (*PushResponse) ProtoReflect 

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

func (*PushResponse) Reset 

func (x *PushResponse) Reset()

func (*PushResponse) String 

func (x *PushResponse) String() string

func (*PushResponse) Validate 

func (m *PushResponse) Validate() error

Validate checks the field values on PushResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PushResponse) ValidateAll 

func (m *PushResponse) ValidateAll() error

ValidateAll checks the field values on PushResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PushResponseMultiError, or nil if none found.

type PushResponseMultiError 

type PushResponseMultiError []error

PushResponseMultiError is an error wrapping multiple validation errors returned by PushResponse.ValidateAll() if the designated constraints aren't met.

func (PushResponseMultiError) AllErrors 

func (m PushResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PushResponseMultiError) Error 

func (m PushResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PushResponseValidationError 

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

PushResponseValidationError is the validation error returned by PushResponse.Validate if the designated constraints aren't met.

func (PushResponseValidationError) Cause 

func (e PushResponseValidationError) Cause() error

Cause function returns cause value.

func (PushResponseValidationError) Error 

func (e PushResponseValidationError) Error() string

Error satisfies the builtin error interface

func (PushResponseValidationError) ErrorName 

func (e PushResponseValidationError) ErrorName() string

ErrorName returns error name.

func (PushResponseValidationError) Field 

func (e PushResponseValidationError) Field() string

Field function returns field value.

func (PushResponseValidationError) Key 

func (e PushResponseValidationError) Key() bool

Key function returns key value.

func (PushResponseValidationError) Reason 

func (e PushResponseValidationError) Reason() string

Reason function returns reason value.

type PushServiceClient 

type PushServiceClient interface {
	Push(ctx context.Context, in *PushRequest, opts ...grpc.CallOption) (*PushResponse, error)
	Multicast(ctx context.Context, in *MulticastRequest, opts ...grpc.CallOption) (*MulticastResponse, error)
	Broadcast(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (*BroadcastResponse, error)
}

PushServiceClient is the client API for PushService 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.

TCP Gate service Open to the server cluster Provide HTTP and gRPC interfaces

func NewPushServiceClient 

func NewPushServiceClient(cc grpc.ClientConnInterface) PushServiceClient

type PushServiceErrorReason 

type PushServiceErrorReason int32
const (
	PushServiceErrorReason_PUSH_SERVICE_ERROR_REASON_UNSPECIFIED PushServiceErrorReason = 0
	PushServiceErrorReason_PUSH_SERVICE_ERROR_REASON_SERVER      PushServiceErrorReason = 1
	PushServiceErrorReason_PUSH_SERVICE_ERROR_REASON_SERVER_ID   PushServiceErrorReason = 2
)

func (PushServiceErrorReason) Descriptor 

func (PushServiceErrorReason) Descriptor() protoreflect.EnumDescriptor

func (PushServiceErrorReason) Enum 

func (x PushServiceErrorReason) Enum() *PushServiceErrorReason

func (PushServiceErrorReason) EnumDescriptor deprecated 

func (PushServiceErrorReason) EnumDescriptor() ([]byte, []int)

Deprecated: Use PushServiceErrorReason.Descriptor instead.

func (PushServiceErrorReason) Number 

func (x PushServiceErrorReason) Number() protoreflect.EnumNumber

func (PushServiceErrorReason) String 

func (x PushServiceErrorReason) String() string

func (PushServiceErrorReason) Type 

func (PushServiceErrorReason) Type() protoreflect.EnumType

type PushServiceHTTPClient 

type PushServiceHTTPClient interface {
	Broadcast(ctx context.Context, req *BroadcastRequest, opts ...http.CallOption) (rsp *BroadcastResponse, err error)
	Multicast(ctx context.Context, req *MulticastRequest, opts ...http.CallOption) (rsp *MulticastResponse, err error)
	Push(ctx context.Context, req *PushRequest, opts ...http.CallOption) (rsp *PushResponse, err error)
}

func NewPushServiceHTTPClient 

func NewPushServiceHTTPClient(client *http.Client) PushServiceHTTPClient

type PushServiceHTTPClientImpl 

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

func (*PushServiceHTTPClientImpl) Broadcast 

func (c *PushServiceHTTPClientImpl) Broadcast(ctx context.Context, in *BroadcastRequest, opts ...http.CallOption) (*BroadcastResponse, error)

func (*PushServiceHTTPClientImpl) Multicast 

func (c *PushServiceHTTPClientImpl) Multicast(ctx context.Context, in *MulticastRequest, opts ...http.CallOption) (*MulticastResponse, error)

func (*PushServiceHTTPClientImpl) Push 

func (c *PushServiceHTTPClientImpl) Push(ctx context.Context, in *PushRequest, opts ...http.CallOption) (*PushResponse, error)

type PushServiceHTTPServer 

type PushServiceHTTPServer interface {
	Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, error)
	Multicast(context.Context, *MulticastRequest) (*MulticastResponse, error)
	Push(context.Context, *PushRequest) (*PushResponse, error)
}

type PushServiceServer 

type PushServiceServer interface {
	Push(context.Context, *PushRequest) (*PushResponse, error)
	Multicast(context.Context, *MulticastRequest) (*MulticastResponse, error)
	Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, error)
	// contains filtered or unexported methods
}

PushServiceServer is the server API for PushService service. All implementations must embed UnimplementedPushServiceServer for forward compatibility.

TCP Gate service Open to the server cluster Provide HTTP and gRPC interfaces

type UnimplementedPushServiceServer 

type UnimplementedPushServiceServer struct{}

UnimplementedPushServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedPushServiceServer) Broadcast 

func (UnimplementedPushServiceServer) Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, error)

func (UnimplementedPushServiceServer) Multicast 

func (UnimplementedPushServiceServer) Multicast(context.Context, *MulticastRequest) (*MulticastResponse, error)

func (UnimplementedPushServiceServer) Push 

func (UnimplementedPushServiceServer) Push(context.Context, *PushRequest) (*PushResponse, error)

type UnsafePushServiceServer 

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

UnsafePushServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PushServiceServer 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.