pushtypes

package
v1.10.0 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2023 License: Apache-2.0, MIT Imports: 17 Imported by: 0

Documentation

Overview

Package pushtypes is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const ServicePushPayloadKey = "p"

Variables

View Source 
var (
	ErrInvalidLengthPushtypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPushtypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPushtypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var DecryptedPush_PushType_name = map[int32]string{
	0:  "Unknown",
	1:  "Message",
	7:  "GroupInvitation",
	8:  "ConversationNameChanged",
	9:  "MemberNameChanged",
	11: "MemberDetailsChanged",
}
View Source 
var DecryptedPush_PushType_value = map[string]int32{
	"Unknown":                 0,
	"Message":                 1,
	"GroupInvitation":         7,
	"ConversationNameChanged": 8,
	"MemberNameChanged":       9,
	"MemberDetailsChanged":    11,
}
View Source 
var PushServicePriority_name = map[int32]string{
	0: "PushPriorityUndefined",
	1: "PushPriorityLow",
	2: "PushPriorityNormal",
}
View Source 
var PushServicePriority_value = map[string]int32{
	"PushPriorityUndefined": 0,
	"PushPriorityLow":       1,
	"PushPriorityNormal":    2,
}
View Source 
var PushServiceTokenType_name = map[int32]string{
	0: "PushTokenUndefined",
	1: "PushTokenMQTT",
	2: "PushTokenApplePushNotificationService",
	3: "PushTokenFirebaseCloudMessaging",
	4: "PushTokenWindowsPushNotificationService",
	5: "PushTokenHuaweiPushKit",
	6: "PushTokenAmazonDeviceMessaging",
}
View Source 
var PushServiceTokenType_value = map[string]int32{
	"PushTokenUndefined":                      0,
	"PushTokenMQTT":                           1,
	"PushTokenApplePushNotificationService":   2,
	"PushTokenFirebaseCloudMessaging":         3,
	"PushTokenWindowsPushNotificationService": 4,
	"PushTokenHuaweiPushKit":                  5,
	"PushTokenAmazonDeviceMessaging":          6,
}
View Source 
var PushService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "weshnet.push.v1.PushService",
	HandlerType: (*PushServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ServerInfo",
			Handler:    _PushService_ServerInfo_Handler,
		},
		{
			MethodName: "Send",
			Handler:    _PushService_Send_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pushtypes/pushtypes.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 RegisterPushServiceHandler 

func RegisterPushServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterPushServiceHandler registers the http handlers for service PushService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterPushServiceHandlerClient 

func RegisterPushServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client PushServiceClient) error

RegisterPushServiceHandlerClient registers the http handlers for service PushService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "PushServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "PushServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "PushServiceClient" to call the correct interceptors.

func RegisterPushServiceHandlerFromEndpoint 

func RegisterPushServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterPushServiceHandlerFromEndpoint is same as RegisterPushServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterPushServiceHandlerServer 

func RegisterPushServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server PushServiceServer) error

RegisterPushServiceHandlerServer registers the http handlers for service PushService to "mux". UnaryRPC :call PushServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterPushServiceHandlerFromEndpoint instead.

func RegisterPushServiceServer 

func RegisterPushServiceServer(s grpc.ServiceRegistrar, srv PushServiceServer)

Types

type DecryptedPush 

type DecryptedPush struct {
	AccountID               string                 `protobuf:"bytes,1,opt,name=account_id,json=accountId,proto3" json:"account_id,omitempty"`
	AccountName             string                 `protobuf:"bytes,2,opt,name=account_name,json=accountName,proto3" json:"account_name,omitempty"`
	ConversationPublicKey   string                 `` /* 126-byte string literal not displayed */
	ConversationDisplayName string                 `` /* 132-byte string literal not displayed */
	MemberPublicKey         string                 `protobuf:"bytes,5,opt,name=member_public_key,json=memberPublicKey,proto3" json:"member_public_key,omitempty"`
	MemberDisplayName       string                 `protobuf:"bytes,6,opt,name=member_display_name,json=memberDisplayName,proto3" json:"member_display_name,omitempty"`
	PushType                DecryptedPush_PushType `` /* 130-byte string literal not displayed */
	PayloadAttrsJSON        string                 `protobuf:"bytes,8,opt,name=payload_attrs_json,json=payloadAttrsJson,proto3" json:"payload_attrs_json,omitempty"`
	DeepLink                string                 `protobuf:"bytes,9,opt,name=deep_link,json=deepLink,proto3" json:"deep_link,omitempty"`
	AlreadyReceived         bool                   `protobuf:"varint,10,opt,name=already_received,json=alreadyReceived,proto3" json:"already_received,omitempty"`
	AccountMuted            bool                   `protobuf:"varint,11,opt,name=account_muted,json=accountMuted,proto3" json:"account_muted,omitempty"`
	ConversationMuted       bool                   `protobuf:"varint,12,opt,name=conversation_muted,json=conversationMuted,proto3" json:"conversation_muted,omitempty"`
	HidePreview             bool                   `protobuf:"varint,13,opt,name=hide_preview,json=hidePreview,proto3" json:"hide_preview,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}               `json:"-"`
	XXX_unrecognized        []byte                 `json:"-"`
	XXX_sizecache           int32                  `json:"-"`
}

func (*DecryptedPush) Descriptor 

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

func (*DecryptedPush) GetAccountID 

func (m *DecryptedPush) GetAccountID() string

func (*DecryptedPush) GetAccountMuted 

func (m *DecryptedPush) GetAccountMuted() bool

func (*DecryptedPush) GetAccountName 

func (m *DecryptedPush) GetAccountName() string

func (*DecryptedPush) GetAlreadyReceived 

func (m *DecryptedPush) GetAlreadyReceived() bool

func (*DecryptedPush) GetConversationDisplayName 

func (m *DecryptedPush) GetConversationDisplayName() string

func (*DecryptedPush) GetConversationMuted 

func (m *DecryptedPush) GetConversationMuted() bool

func (*DecryptedPush) GetConversationPublicKey 

func (m *DecryptedPush) GetConversationPublicKey() string
func (m *DecryptedPush) GetDeepLink() string

func (*DecryptedPush) GetHidePreview 

func (m *DecryptedPush) GetHidePreview() bool

func (*DecryptedPush) GetMemberDisplayName 

func (m *DecryptedPush) GetMemberDisplayName() string

func (*DecryptedPush) GetMemberPublicKey 

func (m *DecryptedPush) GetMemberPublicKey() string

func (*DecryptedPush) GetPayloadAttrsJSON 

func (m *DecryptedPush) GetPayloadAttrsJSON() string

func (*DecryptedPush) GetPushType 

func (m *DecryptedPush) GetPushType() DecryptedPush_PushType

func (*DecryptedPush) Marshal 

func (m *DecryptedPush) Marshal() (dAtA []byte, err error)

func (*DecryptedPush) MarshalTo 

func (m *DecryptedPush) MarshalTo(dAtA []byte) (int, error)

func (*DecryptedPush) MarshalToSizedBuffer 

func (m *DecryptedPush) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DecryptedPush) ProtoMessage 

func (*DecryptedPush) ProtoMessage()

func (*DecryptedPush) Reset 

func (m *DecryptedPush) Reset()

func (*DecryptedPush) Size 

func (m *DecryptedPush) Size() (n int)

func (*DecryptedPush) String 

func (m *DecryptedPush) String() string

func (*DecryptedPush) Unmarshal 

func (m *DecryptedPush) Unmarshal(dAtA []byte) error

func (*DecryptedPush) XXX_DiscardUnknown 

func (m *DecryptedPush) XXX_DiscardUnknown()

func (*DecryptedPush) XXX_Marshal 

func (m *DecryptedPush) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DecryptedPush) XXX_Merge 

func (m *DecryptedPush) XXX_Merge(src proto.Message)

func (*DecryptedPush) XXX_Size 

func (m *DecryptedPush) XXX_Size() int

func (*DecryptedPush) XXX_Unmarshal 

func (m *DecryptedPush) XXX_Unmarshal(b []byte) error

type DecryptedPush_PushType 

type DecryptedPush_PushType int32
const (
	DecryptedPush_Unknown                 DecryptedPush_PushType = 0
	DecryptedPush_Message                 DecryptedPush_PushType = 1
	DecryptedPush_GroupInvitation         DecryptedPush_PushType = 7
	DecryptedPush_ConversationNameChanged DecryptedPush_PushType = 8
	DecryptedPush_MemberNameChanged       DecryptedPush_PushType = 9
	DecryptedPush_MemberDetailsChanged    DecryptedPush_PushType = 11
)

func (DecryptedPush_PushType) EnumDescriptor 

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

func (DecryptedPush_PushType) String 

func (x DecryptedPush_PushType) String() string

type FormatedPush 

type FormatedPush struct {
	PushType               DecryptedPush_PushType `` /* 130-byte string literal not displayed */
	Title                  string                 `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Subtitle               string                 `protobuf:"bytes,3,opt,name=subtitle,proto3" json:"subtitle,omitempty"`
	Body                   string                 `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"`
	DeepLink               string                 `protobuf:"bytes,5,opt,name=deep_link,json=deepLink,proto3" json:"deep_link,omitempty"`
	Muted                  bool                   `protobuf:"varint,6,opt,name=muted,proto3" json:"muted,omitempty"`
	HidePreview            bool                   `protobuf:"varint,7,opt,name=hide_preview,json=hidePreview,proto3" json:"hide_preview,omitempty"`
	ConversationIdentifier string                 `` /* 127-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}               `json:"-"`
	XXX_unrecognized       []byte                 `json:"-"`
	XXX_sizecache          int32                  `json:"-"`
}

func (*FormatedPush) Descriptor 

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

func (*FormatedPush) GetBody 

func (m *FormatedPush) GetBody() string

func (*FormatedPush) GetConversationIdentifier 

func (m *FormatedPush) GetConversationIdentifier() string
func (m *FormatedPush) GetDeepLink() string

func (*FormatedPush) GetHidePreview 

func (m *FormatedPush) GetHidePreview() bool

func (*FormatedPush) GetMuted 

func (m *FormatedPush) GetMuted() bool

func (*FormatedPush) GetPushType 

func (m *FormatedPush) GetPushType() DecryptedPush_PushType

func (*FormatedPush) GetSubtitle 

func (m *FormatedPush) GetSubtitle() string

func (*FormatedPush) GetTitle 

func (m *FormatedPush) GetTitle() string

func (*FormatedPush) Marshal 

func (m *FormatedPush) Marshal() (dAtA []byte, err error)

func (*FormatedPush) MarshalTo 

func (m *FormatedPush) MarshalTo(dAtA []byte) (int, error)

func (*FormatedPush) MarshalToSizedBuffer 

func (m *FormatedPush) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*FormatedPush) ProtoMessage 

func (*FormatedPush) ProtoMessage()

func (*FormatedPush) Reset 

func (m *FormatedPush) Reset()

func (*FormatedPush) Size 

func (m *FormatedPush) Size() (n int)

func (*FormatedPush) String 

func (m *FormatedPush) String() string

func (*FormatedPush) Unmarshal 

func (m *FormatedPush) Unmarshal(dAtA []byte) error

func (*FormatedPush) XXX_DiscardUnknown 

func (m *FormatedPush) XXX_DiscardUnknown()

func (*FormatedPush) XXX_Marshal 

func (m *FormatedPush) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FormatedPush) XXX_Merge 

func (m *FormatedPush) XXX_Merge(src proto.Message)

func (*FormatedPush) XXX_Size 

func (m *FormatedPush) XXX_Size() int

func (*FormatedPush) XXX_Unmarshal 

func (m *FormatedPush) XXX_Unmarshal(b []byte) error

type OutOfStoreExposedData added in v1.3.2 

type OutOfStoreExposedData struct {
	Nonce                []byte   `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Box                  []byte   `protobuf:"bytes,2,opt,name=box,proto3" json:"box,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OutOfStoreExposedData) Descriptor added in v1.3.2 

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

func (*OutOfStoreExposedData) GetBox added in v1.3.2 

func (m *OutOfStoreExposedData) GetBox() []byte

func (*OutOfStoreExposedData) GetNonce added in v1.3.2 

func (m *OutOfStoreExposedData) GetNonce() []byte

func (*OutOfStoreExposedData) Marshal added in v1.3.2 

func (m *OutOfStoreExposedData) Marshal() (dAtA []byte, err error)

func (*OutOfStoreExposedData) MarshalTo added in v1.3.2 

func (m *OutOfStoreExposedData) MarshalTo(dAtA []byte) (int, error)

func (*OutOfStoreExposedData) MarshalToSizedBuffer added in v1.3.2 

func (m *OutOfStoreExposedData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OutOfStoreExposedData) ProtoMessage added in v1.3.2 

func (*OutOfStoreExposedData) ProtoMessage()

func (*OutOfStoreExposedData) Reset added in v1.3.2 

func (m *OutOfStoreExposedData) Reset()

func (*OutOfStoreExposedData) Size added in v1.3.2 

func (m *OutOfStoreExposedData) Size() (n int)

func (*OutOfStoreExposedData) String added in v1.3.2 

func (m *OutOfStoreExposedData) String() string

func (*OutOfStoreExposedData) Unmarshal added in v1.3.2 

func (m *OutOfStoreExposedData) Unmarshal(dAtA []byte) error

func (*OutOfStoreExposedData) XXX_DiscardUnknown added in v1.3.2 

func (m *OutOfStoreExposedData) XXX_DiscardUnknown()

func (*OutOfStoreExposedData) XXX_Marshal added in v1.3.2 

func (m *OutOfStoreExposedData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OutOfStoreExposedData) XXX_Merge added in v1.3.2 

func (m *OutOfStoreExposedData) XXX_Merge(src proto.Message)

func (*OutOfStoreExposedData) XXX_Size added in v1.3.2 

func (m *OutOfStoreExposedData) XXX_Size() int

func (*OutOfStoreExposedData) XXX_Unmarshal added in v1.3.2 

func (m *OutOfStoreExposedData) XXX_Unmarshal(b []byte) error

type OutOfStoreMessageEnvelope 

type OutOfStoreMessageEnvelope struct {
	Nonce                []byte   `protobuf:"bytes,1,opt,name=nonce,proto3" json:"nonce,omitempty"`
	Box                  []byte   `protobuf:"bytes,2,opt,name=box,proto3" json:"box,omitempty"`
	GroupReference       []byte   `protobuf:"bytes,4,opt,name=group_reference,json=groupReference,proto3" json:"group_reference,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*OutOfStoreMessageEnvelope) Descriptor 

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

func (*OutOfStoreMessageEnvelope) GetBox 

func (m *OutOfStoreMessageEnvelope) GetBox() []byte

func (*OutOfStoreMessageEnvelope) GetGroupReference 

func (m *OutOfStoreMessageEnvelope) GetGroupReference() []byte

func (*OutOfStoreMessageEnvelope) GetNonce 

func (m *OutOfStoreMessageEnvelope) GetNonce() []byte

func (*OutOfStoreMessageEnvelope) Marshal 

func (m *OutOfStoreMessageEnvelope) Marshal() (dAtA []byte, err error)

func (*OutOfStoreMessageEnvelope) MarshalTo 

func (m *OutOfStoreMessageEnvelope) MarshalTo(dAtA []byte) (int, error)

func (*OutOfStoreMessageEnvelope) MarshalToSizedBuffer 

func (m *OutOfStoreMessageEnvelope) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OutOfStoreMessageEnvelope) ProtoMessage 

func (*OutOfStoreMessageEnvelope) ProtoMessage()

func (*OutOfStoreMessageEnvelope) Reset 

func (m *OutOfStoreMessageEnvelope) Reset()

func (*OutOfStoreMessageEnvelope) Size 

func (m *OutOfStoreMessageEnvelope) Size() (n int)

func (*OutOfStoreMessageEnvelope) String 

func (m *OutOfStoreMessageEnvelope) String() string

func (*OutOfStoreMessageEnvelope) Unmarshal 

func (m *OutOfStoreMessageEnvelope) Unmarshal(dAtA []byte) error

func (*OutOfStoreMessageEnvelope) XXX_DiscardUnknown 

func (m *OutOfStoreMessageEnvelope) XXX_DiscardUnknown()

func (*OutOfStoreMessageEnvelope) XXX_Marshal 

func (m *OutOfStoreMessageEnvelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OutOfStoreMessageEnvelope) XXX_Merge 

func (m *OutOfStoreMessageEnvelope) XXX_Merge(src proto.Message)

func (*OutOfStoreMessageEnvelope) XXX_Size 

func (m *OutOfStoreMessageEnvelope) XXX_Size() int

func (*OutOfStoreMessageEnvelope) XXX_Unmarshal 

func (m *OutOfStoreMessageEnvelope) XXX_Unmarshal(b []byte) error

type PushServiceClient 

type PushServiceClient interface {
	// ServerInfo retrieves metadata about the current push service
	ServerInfo(ctx context.Context, in *PushServiceServerInfo_Request, opts ...grpc.CallOption) (*PushServiceServerInfo_Reply, error)
	// Send dispatch a push payload to one or multiple recipients
	Send(ctx context.Context, in *PushServiceSend_Request, opts ...grpc.CallOption) (*PushServiceSend_Reply, 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.

func NewPushServiceClient 

func NewPushServiceClient(cc grpc.ClientConnInterface) PushServiceClient

type PushServiceOpaqueReceiver 

type PushServiceOpaqueReceiver struct {
	OpaqueToken          []byte   `protobuf:"bytes,1,opt,name=opaque_token,json=opaqueToken,proto3" json:"opaque_token,omitempty"`
	ServiceAddr          string   `protobuf:"bytes,2,opt,name=service_addr,json=serviceAddr,proto3" json:"service_addr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushServiceOpaqueReceiver) Descriptor 

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

func (*PushServiceOpaqueReceiver) GetOpaqueToken 

func (m *PushServiceOpaqueReceiver) GetOpaqueToken() []byte

func (*PushServiceOpaqueReceiver) GetServiceAddr 

func (m *PushServiceOpaqueReceiver) GetServiceAddr() string

func (*PushServiceOpaqueReceiver) Marshal 

func (m *PushServiceOpaqueReceiver) Marshal() (dAtA []byte, err error)

func (*PushServiceOpaqueReceiver) MarshalTo 

func (m *PushServiceOpaqueReceiver) MarshalTo(dAtA []byte) (int, error)

func (*PushServiceOpaqueReceiver) MarshalToSizedBuffer 

func (m *PushServiceOpaqueReceiver) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushServiceOpaqueReceiver) ProtoMessage 

func (*PushServiceOpaqueReceiver) ProtoMessage()

func (*PushServiceOpaqueReceiver) Reset 

func (m *PushServiceOpaqueReceiver) Reset()

func (*PushServiceOpaqueReceiver) Size 

func (m *PushServiceOpaqueReceiver) Size() (n int)

func (*PushServiceOpaqueReceiver) String 

func (m *PushServiceOpaqueReceiver) String() string

func (*PushServiceOpaqueReceiver) Unmarshal 

func (m *PushServiceOpaqueReceiver) Unmarshal(dAtA []byte) error

func (*PushServiceOpaqueReceiver) XXX_DiscardUnknown 

func (m *PushServiceOpaqueReceiver) XXX_DiscardUnknown()

func (*PushServiceOpaqueReceiver) XXX_Marshal 

func (m *PushServiceOpaqueReceiver) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushServiceOpaqueReceiver) XXX_Merge 

func (m *PushServiceOpaqueReceiver) XXX_Merge(src proto.Message)

func (*PushServiceOpaqueReceiver) XXX_Size 

func (m *PushServiceOpaqueReceiver) XXX_Size() int

func (*PushServiceOpaqueReceiver) XXX_Unmarshal 

func (m *PushServiceOpaqueReceiver) XXX_Unmarshal(b []byte) error

type PushServicePriority 

type PushServicePriority int32
const (
	PushServicePriority_PushPriorityUndefined PushServicePriority = 0
	PushServicePriority_PushPriorityLow       PushServicePriority = 1
	PushServicePriority_PushPriorityNormal    PushServicePriority = 2
)

func (PushServicePriority) EnumDescriptor 

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

func (PushServicePriority) String 

func (x PushServicePriority) String() string

type PushServiceSend 

type PushServiceSend struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushServiceSend) Descriptor 

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

func (*PushServiceSend) Marshal 

func (m *PushServiceSend) Marshal() (dAtA []byte, err error)

func (*PushServiceSend) MarshalTo 

func (m *PushServiceSend) MarshalTo(dAtA []byte) (int, error)

func (*PushServiceSend) MarshalToSizedBuffer 

func (m *PushServiceSend) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushServiceSend) ProtoMessage 

func (*PushServiceSend) ProtoMessage()

func (*PushServiceSend) Reset 

func (m *PushServiceSend) Reset()

func (*PushServiceSend) Size 

func (m *PushServiceSend) Size() (n int)

func (*PushServiceSend) String 

func (m *PushServiceSend) String() string

func (*PushServiceSend) Unmarshal 

func (m *PushServiceSend) Unmarshal(dAtA []byte) error

func (*PushServiceSend) XXX_DiscardUnknown 

func (m *PushServiceSend) XXX_DiscardUnknown()

func (*PushServiceSend) XXX_Marshal 

func (m *PushServiceSend) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushServiceSend) XXX_Merge 

func (m *PushServiceSend) XXX_Merge(src proto.Message)

func (*PushServiceSend) XXX_Size 

func (m *PushServiceSend) XXX_Size() int

func (*PushServiceSend) XXX_Unmarshal 

func (m *PushServiceSend) XXX_Unmarshal(b []byte) error

type PushServiceSend_Reply 

type PushServiceSend_Reply struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushServiceSend_Reply) Descriptor 

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

func (*PushServiceSend_Reply) Marshal 

func (m *PushServiceSend_Reply) Marshal() (dAtA []byte, err error)

func (*PushServiceSend_Reply) MarshalTo 

func (m *PushServiceSend_Reply) MarshalTo(dAtA []byte) (int, error)

func (*PushServiceSend_Reply) MarshalToSizedBuffer 

func (m *PushServiceSend_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushServiceSend_Reply) ProtoMessage 

func (*PushServiceSend_Reply) ProtoMessage()

func (*PushServiceSend_Reply) Reset 

func (m *PushServiceSend_Reply) Reset()

func (*PushServiceSend_Reply) Size 

func (m *PushServiceSend_Reply) Size() (n int)

func (*PushServiceSend_Reply) String 

func (m *PushServiceSend_Reply) String() string

func (*PushServiceSend_Reply) Unmarshal 

func (m *PushServiceSend_Reply) Unmarshal(dAtA []byte) error

func (*PushServiceSend_Reply) XXX_DiscardUnknown 

func (m *PushServiceSend_Reply) XXX_DiscardUnknown()

func (*PushServiceSend_Reply) XXX_Marshal 

func (m *PushServiceSend_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushServiceSend_Reply) XXX_Merge 

func (m *PushServiceSend_Reply) XXX_Merge(src proto.Message)

func (*PushServiceSend_Reply) XXX_Size 

func (m *PushServiceSend_Reply) XXX_Size() int

func (*PushServiceSend_Reply) XXX_Unmarshal 

func (m *PushServiceSend_Reply) XXX_Unmarshal(b []byte) error

type PushServiceSend_Request 

type PushServiceSend_Request struct {
	Envelope             *OutOfStoreMessageEnvelope   `protobuf:"bytes,1,opt,name=envelope,proto3" json:"envelope,omitempty"`
	Priority             PushServicePriority          `protobuf:"varint,2,opt,name=priority,proto3,enum=weshnet.push.v1.PushServicePriority" json:"priority,omitempty"`
	Receivers            []*PushServiceOpaqueReceiver `protobuf:"bytes,3,rep,name=receivers,proto3" json:"receivers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*PushServiceSend_Request) Descriptor 

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

func (*PushServiceSend_Request) GetEnvelope 

func (m *PushServiceSend_Request) GetEnvelope() *OutOfStoreMessageEnvelope

func (*PushServiceSend_Request) GetPriority 

func (m *PushServiceSend_Request) GetPriority() PushServicePriority

func (*PushServiceSend_Request) GetReceivers 

func (m *PushServiceSend_Request) GetReceivers() []*PushServiceOpaqueReceiver

func (*PushServiceSend_Request) Marshal 

func (m *PushServiceSend_Request) Marshal() (dAtA []byte, err error)

func (*PushServiceSend_Request) MarshalTo 

func (m *PushServiceSend_Request) MarshalTo(dAtA []byte) (int, error)

func (*PushServiceSend_Request) MarshalToSizedBuffer 

func (m *PushServiceSend_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushServiceSend_Request) ProtoMessage 

func (*PushServiceSend_Request) ProtoMessage()

func (*PushServiceSend_Request) Reset 

func (m *PushServiceSend_Request) Reset()

func (*PushServiceSend_Request) Size 

func (m *PushServiceSend_Request) Size() (n int)

func (*PushServiceSend_Request) String 

func (m *PushServiceSend_Request) String() string

func (*PushServiceSend_Request) Unmarshal 

func (m *PushServiceSend_Request) Unmarshal(dAtA []byte) error

func (*PushServiceSend_Request) XXX_DiscardUnknown 

func (m *PushServiceSend_Request) XXX_DiscardUnknown()

func (*PushServiceSend_Request) XXX_Marshal 

func (m *PushServiceSend_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushServiceSend_Request) XXX_Merge 

func (m *PushServiceSend_Request) XXX_Merge(src proto.Message)

func (*PushServiceSend_Request) XXX_Size 

func (m *PushServiceSend_Request) XXX_Size() int

func (*PushServiceSend_Request) XXX_Unmarshal 

func (m *PushServiceSend_Request) XXX_Unmarshal(b []byte) error

type PushServiceServer 

type PushServiceServer interface {
	// ServerInfo retrieves metadata about the current push service
	ServerInfo(context.Context, *PushServiceServerInfo_Request) (*PushServiceServerInfo_Reply, error)
	// Send dispatch a push payload to one or multiple recipients
	Send(context.Context, *PushServiceSend_Request) (*PushServiceSend_Reply, error)
	// contains filtered or unexported methods
}

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

type PushServiceServerInfo 

type PushServiceServerInfo struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushServiceServerInfo) Descriptor 

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

func (*PushServiceServerInfo) Marshal 

func (m *PushServiceServerInfo) Marshal() (dAtA []byte, err error)

func (*PushServiceServerInfo) MarshalTo 

func (m *PushServiceServerInfo) MarshalTo(dAtA []byte) (int, error)

func (*PushServiceServerInfo) MarshalToSizedBuffer 

func (m *PushServiceServerInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushServiceServerInfo) ProtoMessage 

func (*PushServiceServerInfo) ProtoMessage()

func (*PushServiceServerInfo) Reset 

func (m *PushServiceServerInfo) Reset()

func (*PushServiceServerInfo) Size 

func (m *PushServiceServerInfo) Size() (n int)

func (*PushServiceServerInfo) String 

func (m *PushServiceServerInfo) String() string

func (*PushServiceServerInfo) Unmarshal 

func (m *PushServiceServerInfo) Unmarshal(dAtA []byte) error

func (*PushServiceServerInfo) XXX_DiscardUnknown 

func (m *PushServiceServerInfo) XXX_DiscardUnknown()

func (*PushServiceServerInfo) XXX_Marshal 

func (m *PushServiceServerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushServiceServerInfo) XXX_Merge 

func (m *PushServiceServerInfo) XXX_Merge(src proto.Message)

func (*PushServiceServerInfo) XXX_Size 

func (m *PushServiceServerInfo) XXX_Size() int

func (*PushServiceServerInfo) XXX_Unmarshal 

func (m *PushServiceServerInfo) XXX_Unmarshal(b []byte) error

type PushServiceServerInfo_Reply 

type PushServiceServerInfo_Reply struct {
	// public_key the public key used to encrypt data to the server (ie. a PushServiceReceiver),
	// to be used with NaCl's Seal and Open
	PublicKey []byte `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// supported_token_types list of token types supported by the server
	SupportedTokenTypes  []*PushServiceSupportedTokenType `protobuf:"bytes,2,rep,name=supported_token_types,json=supportedTokenTypes,proto3" json:"supported_token_types,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*PushServiceServerInfo_Reply) Descriptor 

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

func (*PushServiceServerInfo_Reply) GetPublicKey 

func (m *PushServiceServerInfo_Reply) GetPublicKey() []byte

func (*PushServiceServerInfo_Reply) GetSupportedTokenTypes 

func (m *PushServiceServerInfo_Reply) GetSupportedTokenTypes() []*PushServiceSupportedTokenType

func (*PushServiceServerInfo_Reply) Marshal 

func (m *PushServiceServerInfo_Reply) Marshal() (dAtA []byte, err error)

func (*PushServiceServerInfo_Reply) MarshalTo 

func (m *PushServiceServerInfo_Reply) MarshalTo(dAtA []byte) (int, error)

func (*PushServiceServerInfo_Reply) MarshalToSizedBuffer 

func (m *PushServiceServerInfo_Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushServiceServerInfo_Reply) ProtoMessage 

func (*PushServiceServerInfo_Reply) ProtoMessage()

func (*PushServiceServerInfo_Reply) Reset 

func (m *PushServiceServerInfo_Reply) Reset()

func (*PushServiceServerInfo_Reply) Size 

func (m *PushServiceServerInfo_Reply) Size() (n int)

func (*PushServiceServerInfo_Reply) String 

func (m *PushServiceServerInfo_Reply) String() string

func (*PushServiceServerInfo_Reply) Unmarshal 

func (m *PushServiceServerInfo_Reply) Unmarshal(dAtA []byte) error

func (*PushServiceServerInfo_Reply) XXX_DiscardUnknown 

func (m *PushServiceServerInfo_Reply) XXX_DiscardUnknown()

func (*PushServiceServerInfo_Reply) XXX_Marshal 

func (m *PushServiceServerInfo_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushServiceServerInfo_Reply) XXX_Merge 

func (m *PushServiceServerInfo_Reply) XXX_Merge(src proto.Message)

func (*PushServiceServerInfo_Reply) XXX_Size 

func (m *PushServiceServerInfo_Reply) XXX_Size() int

func (*PushServiceServerInfo_Reply) XXX_Unmarshal 

func (m *PushServiceServerInfo_Reply) XXX_Unmarshal(b []byte) error

type PushServiceServerInfo_Request 

type PushServiceServerInfo_Request struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushServiceServerInfo_Request) Descriptor 

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

func (*PushServiceServerInfo_Request) Marshal 

func (m *PushServiceServerInfo_Request) Marshal() (dAtA []byte, err error)

func (*PushServiceServerInfo_Request) MarshalTo 

func (m *PushServiceServerInfo_Request) MarshalTo(dAtA []byte) (int, error)

func (*PushServiceServerInfo_Request) MarshalToSizedBuffer 

func (m *PushServiceServerInfo_Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushServiceServerInfo_Request) ProtoMessage 

func (*PushServiceServerInfo_Request) ProtoMessage()

func (*PushServiceServerInfo_Request) Reset 

func (m *PushServiceServerInfo_Request) Reset()

func (*PushServiceServerInfo_Request) Size 

func (m *PushServiceServerInfo_Request) Size() (n int)

func (*PushServiceServerInfo_Request) String 

func (m *PushServiceServerInfo_Request) String() string

func (*PushServiceServerInfo_Request) Unmarshal 

func (m *PushServiceServerInfo_Request) Unmarshal(dAtA []byte) error

func (*PushServiceServerInfo_Request) XXX_DiscardUnknown 

func (m *PushServiceServerInfo_Request) XXX_DiscardUnknown()

func (*PushServiceServerInfo_Request) XXX_Marshal 

func (m *PushServiceServerInfo_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushServiceServerInfo_Request) XXX_Merge 

func (m *PushServiceServerInfo_Request) XXX_Merge(src proto.Message)

func (*PushServiceServerInfo_Request) XXX_Size 

func (m *PushServiceServerInfo_Request) XXX_Size() int

func (*PushServiceServerInfo_Request) XXX_Unmarshal 

func (m *PushServiceServerInfo_Request) XXX_Unmarshal(b []byte) error

type PushServiceSupportedTokenType 

type PushServiceSupportedTokenType struct {
	AppBundleID          string               `protobuf:"bytes,1,opt,name=app_bundle_id,json=appBundleId,proto3" json:"app_bundle_id,omitempty"`
	TokenType            PushServiceTokenType `` /* 131-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*PushServiceSupportedTokenType) Descriptor 

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

func (*PushServiceSupportedTokenType) GetAppBundleID 

func (m *PushServiceSupportedTokenType) GetAppBundleID() string

func (*PushServiceSupportedTokenType) GetTokenType 

func (m *PushServiceSupportedTokenType) GetTokenType() PushServiceTokenType

func (*PushServiceSupportedTokenType) Marshal 

func (m *PushServiceSupportedTokenType) Marshal() (dAtA []byte, err error)

func (*PushServiceSupportedTokenType) MarshalTo 

func (m *PushServiceSupportedTokenType) MarshalTo(dAtA []byte) (int, error)

func (*PushServiceSupportedTokenType) MarshalToSizedBuffer 

func (m *PushServiceSupportedTokenType) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PushServiceSupportedTokenType) ProtoMessage 

func (*PushServiceSupportedTokenType) ProtoMessage()

func (*PushServiceSupportedTokenType) Reset 

func (m *PushServiceSupportedTokenType) Reset()

func (*PushServiceSupportedTokenType) Size 

func (m *PushServiceSupportedTokenType) Size() (n int)

func (*PushServiceSupportedTokenType) String 

func (m *PushServiceSupportedTokenType) String() string

func (*PushServiceSupportedTokenType) Unmarshal 

func (m *PushServiceSupportedTokenType) Unmarshal(dAtA []byte) error

func (*PushServiceSupportedTokenType) XXX_DiscardUnknown 

func (m *PushServiceSupportedTokenType) XXX_DiscardUnknown()

func (*PushServiceSupportedTokenType) XXX_Marshal 

func (m *PushServiceSupportedTokenType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PushServiceSupportedTokenType) XXX_Merge 

func (m *PushServiceSupportedTokenType) XXX_Merge(src proto.Message)

func (*PushServiceSupportedTokenType) XXX_Size 

func (m *PushServiceSupportedTokenType) XXX_Size() int

func (*PushServiceSupportedTokenType) XXX_Unmarshal 

func (m *PushServiceSupportedTokenType) XXX_Unmarshal(b []byte) error

type PushServiceTokenType 

type PushServiceTokenType int32
const (
	PushServiceTokenType_PushTokenUndefined PushServiceTokenType = 0
	// PushTokenMQTT: Platform independent
	PushServiceTokenType_PushTokenMQTT PushServiceTokenType = 1
	// PushTokenApplePushNotificationService: iOS, iPadOS, tvOS, macOS
	PushServiceTokenType_PushTokenApplePushNotificationService PushServiceTokenType = 2
	// PushTokenFirebaseCloudMessaging: Android with GMS, Chrome OS
	PushServiceTokenType_PushTokenFirebaseCloudMessaging PushServiceTokenType = 3
	// PushTokenWindowsPushNotificationService: Windows, XBox
	PushServiceTokenType_PushTokenWindowsPushNotificationService PushServiceTokenType = 4
	// PushTokenHuaweiPushKit: Huawei Android devices with AppGallery
	PushServiceTokenType_PushTokenHuaweiPushKit PushServiceTokenType = 5
	// PushTokenAmazonDeviceMessaging: Fire OS devices
	PushServiceTokenType_PushTokenAmazonDeviceMessaging PushServiceTokenType = 6
)

func (PushServiceTokenType) EnumDescriptor 

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

func (PushServiceTokenType) String 

func (x PushServiceTokenType) String() string

type UnimplementedPushServiceServer 

type UnimplementedPushServiceServer struct {
}

UnimplementedPushServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPushServiceServer) Send 

func (UnimplementedPushServiceServer) Send(context.Context, *PushServiceSend_Request) (*PushServiceSend_Reply, error)

func (UnimplementedPushServiceServer) ServerInfo 

func (UnimplementedPushServiceServer) ServerInfo(context.Context, *PushServiceServerInfo_Request) (*PushServiceServerInfo_Reply, 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.