pushtypes

package
v2.358.0 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2022 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 (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)
}

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

func (*UnimplementedPushServiceServer) Send 

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

func (*UnimplementedPushServiceServer) ServerInfo 

func (*UnimplementedPushServiceServer) ServerInfo(ctx context.Context, req *PushServiceServerInfo_Request) (*PushServiceServerInfo_Reply, error)

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.