pushtypes

package
v2.339.3 Latest Latest
Warning

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

Go to latest
Published: Dec 31, 2021 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",
	2:  "Reaction",
	3:  "Media",
	4:  "Photo",
	5:  "Gif",
	6:  "VoiceMessage",
	7:  "GroupInvitation",
	8:  "ConversationNameChanged",
	9:  "MemberNameChanged",
	10: "MemberPictureChanged",
	11: "MemberDetailsChanged",
	12: "ReplyOptions",
}
View Source
var DecryptedPush_PushType_value = map[string]int32{
	"Unknown":                 0,
	"Message":                 1,
	"Reaction":                2,
	"Media":                   3,
	"Photo":                   4,
	"Gif":                     5,
	"VoiceMessage":            6,
	"GroupInvitation":         7,
	"ConversationNameChanged": 8,
	"MemberNameChanged":       9,
	"MemberPictureChanged":    10,
	"MemberDetailsChanged":    11,
	"ReplyOptions":            12,
}
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,
}

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.Server, 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 `` /* 128-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"`
	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) GetAccountName

func (m *DecryptedPush) GetAccountName() string

func (*DecryptedPush) GetAlreadyReceived added in v2.316.0

func (m *DecryptedPush) GetAlreadyReceived() bool

func (*DecryptedPush) GetConversationDisplayName

func (m *DecryptedPush) GetConversationDisplayName() string

func (*DecryptedPush) GetConversationPublicKey

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

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_Reaction                DecryptedPush_PushType = 2
	DecryptedPush_Media                   DecryptedPush_PushType = 3
	DecryptedPush_Photo                   DecryptedPush_PushType = 4
	DecryptedPush_Gif                     DecryptedPush_PushType = 5
	DecryptedPush_VoiceMessage            DecryptedPush_PushType = 6
	DecryptedPush_GroupInvitation         DecryptedPush_PushType = 7
	DecryptedPush_ConversationNameChanged DecryptedPush_PushType = 8
	DecryptedPush_MemberNameChanged       DecryptedPush_PushType = 9
	DecryptedPush_MemberPictureChanged    DecryptedPush_PushType = 10
	DecryptedPush_MemberDetailsChanged    DecryptedPush_PushType = 11
	DecryptedPush_ReplyOptions            DecryptedPush_PushType = 12
)

func (DecryptedPush_PushType) EnumDescriptor

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

func (DecryptedPush_PushType) String

func (x DecryptedPush_PushType) String() string

type FormatedPush added in v2.327.0

type FormatedPush struct {
	PushType             DecryptedPush_PushType `` /* 128-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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*FormatedPush) Descriptor added in v2.327.0

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

func (*FormatedPush) GetBody added in v2.327.0

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

func (*FormatedPush) GetPushType added in v2.327.0

func (m *FormatedPush) GetPushType() DecryptedPush_PushType

func (*FormatedPush) GetSubtitle added in v2.327.0

func (m *FormatedPush) GetSubtitle() string

func (*FormatedPush) GetTitle added in v2.327.0

func (m *FormatedPush) GetTitle() string

func (*FormatedPush) Marshal added in v2.327.0

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

func (*FormatedPush) MarshalTo added in v2.327.0

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

func (*FormatedPush) MarshalToSizedBuffer added in v2.327.0

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

func (*FormatedPush) ProtoMessage added in v2.327.0

func (*FormatedPush) ProtoMessage()

func (*FormatedPush) Reset added in v2.327.0

func (m *FormatedPush) Reset()

func (*FormatedPush) Size added in v2.327.0

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

func (*FormatedPush) String added in v2.327.0

func (m *FormatedPush) String() string

func (*FormatedPush) Unmarshal added in v2.327.0

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

func (*FormatedPush) XXX_DiscardUnknown added in v2.327.0

func (m *FormatedPush) XXX_DiscardUnknown()

func (*FormatedPush) XXX_Marshal added in v2.327.0

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

func (*FormatedPush) XXX_Merge added in v2.327.0

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

func (*FormatedPush) XXX_Size added in v2.327.0

func (m *FormatedPush) XXX_Size() int

func (*FormatedPush) XXX_Unmarshal added in v2.327.0

func (m *FormatedPush) 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 added in v2.321.0

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 PushExposedData

type PushExposedData 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 (*PushExposedData) Descriptor

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

func (*PushExposedData) GetBox

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

func (*PushExposedData) GetNonce

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

func (*PushExposedData) Marshal

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

func (*PushExposedData) MarshalTo

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

func (*PushExposedData) MarshalToSizedBuffer

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

func (*PushExposedData) ProtoMessage

func (*PushExposedData) ProtoMessage()

func (*PushExposedData) Reset

func (m *PushExposedData) Reset()

func (*PushExposedData) Size

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

func (*PushExposedData) String

func (m *PushExposedData) String() string

func (*PushExposedData) Unmarshal

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

func (*PushExposedData) XXX_DiscardUnknown

func (m *PushExposedData) XXX_DiscardUnknown()

func (*PushExposedData) XXX_Marshal

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

func (*PushExposedData) XXX_Merge

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

func (*PushExposedData) XXX_Size

func (m *PushExposedData) XXX_Size() int

func (*PushExposedData) XXX_Unmarshal

func (m *PushExposedData) 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPushServiceClient

func NewPushServiceClient(cc *grpc.ClientConn) 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=berty.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 (*PushServiceSend_Request) GetPriority

func (*PushServiceSend_Request) GetReceivers

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)
}

PushServiceServer is the server API for PushService service.

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 (*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 `` /* 129-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 (*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 (*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 can be embedded to have forward compatible implementations.

func (*UnimplementedPushServiceServer) Send

func (*UnimplementedPushServiceServer) ServerInfo

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL