pushtypes

package
v2.470.2 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2024 License: Apache-2.0, MIT Imports: 18 Imported by: 0

Documentation

Overview

Package pushtypes is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	PushService_ServerInfo_FullMethodName = "/berty.push.v1.PushService/ServerInfo"
	PushService_Send_FullMethodName       = "/berty.push.v1.PushService/Send"
)
View Source
const (
	DummyPushServerAddr = "server.test"
	PushMockBundleID    = "tech.berty.mock"
)
View Source
const ServicePushPayloadKey = "p"

Variables

View Source
var (
	ErrInvalidLengthBertypushtypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBertypushtypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBertypushtypes = 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: "berty.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/bertypushtypes.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 `` /* 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"`
	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 added in v2.381.0

func (m *DecryptedPush) GetAccountMuted() bool

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) GetConversationMuted added in v2.381.0

func (m *DecryptedPush) GetConversationMuted() bool

func (*DecryptedPush) GetConversationPublicKey

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

func (*DecryptedPush) GetHidePreview added in v2.381.0

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 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"`
	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 added in v2.327.0

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

func (*FormatedPush) GetBody added in v2.327.0

func (m *FormatedPush) GetBody() string

func (*FormatedPush) GetConversationIdentifier added in v2.381.0

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

func (*FormatedPush) GetHidePreview added in v2.381.0

func (m *FormatedPush) GetHidePreview() bool

func (*FormatedPush) GetMuted added in v2.381.0

func (m *FormatedPush) GetMuted() bool

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 OutOfStoreExposedData added in v2.470.0

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 v2.470.0

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

func (*OutOfStoreExposedData) GetBox added in v2.470.0

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

func (*OutOfStoreExposedData) GetNonce added in v2.470.0

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

func (*OutOfStoreExposedData) Marshal added in v2.470.0

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

func (*OutOfStoreExposedData) MarshalTo added in v2.470.0

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

func (*OutOfStoreExposedData) MarshalToSizedBuffer added in v2.470.0

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

func (*OutOfStoreExposedData) ProtoMessage added in v2.470.0

func (*OutOfStoreExposedData) ProtoMessage()

func (*OutOfStoreExposedData) Reset added in v2.470.0

func (m *OutOfStoreExposedData) Reset()

func (*OutOfStoreExposedData) Size added in v2.470.0

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

func (*OutOfStoreExposedData) String added in v2.470.0

func (m *OutOfStoreExposedData) String() string

func (*OutOfStoreExposedData) Unmarshal added in v2.470.0

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

func (*OutOfStoreExposedData) XXX_DiscardUnknown added in v2.470.0

func (m *OutOfStoreExposedData) XXX_DiscardUnknown()

func (*OutOfStoreExposedData) XXX_Marshal added in v2.470.0

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

func (*OutOfStoreExposedData) XXX_Merge added in v2.470.0

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

func (*OutOfStoreExposedData) XXX_Size added in v2.470.0

func (m *OutOfStoreExposedData) XXX_Size() int

func (*OutOfStoreExposedData) XXX_Unmarshal added in v2.470.0

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

type PushMockedDispatcher added in v2.470.0

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

func NewPushMockedDispatcher added in v2.470.0

func NewPushMockedDispatcher(bundleID string) *PushMockedDispatcher

func (*PushMockedDispatcher) BundleID added in v2.470.0

func (d *PushMockedDispatcher) BundleID() string

func (*PushMockedDispatcher) Debug added in v2.470.0

func (d *PushMockedDispatcher) Debug() string

func (*PushMockedDispatcher) Dispatch added in v2.470.0

func (d *PushMockedDispatcher) Dispatch(data []byte, receiver *PushServiceReceiver) error

func (*PushMockedDispatcher) Len added in v2.470.0

func (d *PushMockedDispatcher) Len(token []byte) int

func (*PushMockedDispatcher) Shift added in v2.470.0

func (d *PushMockedDispatcher) Shift(token []byte) []byte

func (*PushMockedDispatcher) TokenType added in v2.470.0

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.

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 PushServiceReceiver added in v2.470.0

type PushServiceReceiver struct {
	// token_type is the type of the token used, it allows us to act as a proxy to the appropriate push server
	TokenType PushServiceTokenType `` /* 129-byte string literal not displayed */
	// bundle_id is the app identifier
	BundleID string `protobuf:"bytes,2,opt,name=bundle_id,json=bundleId,proto3" json:"bundle_id,omitempty"`
	// token is the device identifier used
	Token []byte `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// public_key is the public key which will be used to encrypt the payload
	RecipientPublicKey   []byte   `protobuf:"bytes,4,opt,name=recipient_public_key,json=recipientPublicKey,proto3" json:"recipient_public_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PushServiceReceiver) Descriptor added in v2.470.0

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

func (*PushServiceReceiver) GetBundleID added in v2.470.0

func (m *PushServiceReceiver) GetBundleID() string

func (*PushServiceReceiver) GetRecipientPublicKey added in v2.470.0

func (m *PushServiceReceiver) GetRecipientPublicKey() []byte

func (*PushServiceReceiver) GetToken added in v2.470.0

func (m *PushServiceReceiver) GetToken() []byte

func (*PushServiceReceiver) GetTokenType added in v2.470.0

func (m *PushServiceReceiver) GetTokenType() PushServiceTokenType

func (*PushServiceReceiver) Marshal added in v2.470.0

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

func (*PushServiceReceiver) MarshalTo added in v2.470.0

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

func (*PushServiceReceiver) MarshalToSizedBuffer added in v2.470.0

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

func (*PushServiceReceiver) ProtoMessage added in v2.470.0

func (*PushServiceReceiver) ProtoMessage()

func (*PushServiceReceiver) Reset added in v2.470.0

func (m *PushServiceReceiver) Reset()

func (*PushServiceReceiver) Size added in v2.470.0

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

func (*PushServiceReceiver) String added in v2.470.0

func (m *PushServiceReceiver) String() string

func (*PushServiceReceiver) Unmarshal added in v2.470.0

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

func (*PushServiceReceiver) XXX_DiscardUnknown added in v2.470.0

func (m *PushServiceReceiver) XXX_DiscardUnknown()

func (*PushServiceReceiver) XXX_Marshal added in v2.470.0

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

func (*PushServiceReceiver) XXX_Merge added in v2.470.0

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

func (*PushServiceReceiver) XXX_Size added in v2.470.0

func (m *PushServiceReceiver) XXX_Size() int

func (*PushServiceReceiver) XXX_Unmarshal added in v2.470.0

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

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             []byte                       `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() []byte

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

func (UnimplementedPushServiceServer) Send

type UnsafePushServiceServer added in v2.470.0

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.

Jump to

Keyboard shortcuts

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