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 

func (d *PushMockedDispatcher) TokenType() PushServiceTokenType

type PushServiceClient 

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

PushServiceClient is the client API for PushService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewPushServiceClient 

func NewPushServiceClient(cc grpc.ClientConnInterface) PushServiceClient

type PushServiceOpaqueReceiver 

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

func (*PushServiceOpaqueReceiver) Descriptor 

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

func (*PushServiceOpaqueReceiver) GetOpaqueToken 

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

func (*PushServiceOpaqueReceiver) GetServiceAddr 

func (m *PushServiceOpaqueReceiver) GetServiceAddr() string

func (*PushServiceOpaqueReceiver) Marshal 

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

func (*PushServiceOpaqueReceiver) MarshalTo 

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

func (*PushServiceOpaqueReceiver) MarshalToSizedBuffer 

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

func (*PushServiceOpaqueReceiver) ProtoMessage 

func (*PushServiceOpaqueReceiver) ProtoMessage()

func (*PushServiceOpaqueReceiver) Reset 

func (m *PushServiceOpaqueReceiver) Reset()

func (*PushServiceOpaqueReceiver) Size 

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

func (*PushServiceOpaqueReceiver) String 

func (m *PushServiceOpaqueReceiver) String() string

func (*PushServiceOpaqueReceiver) Unmarshal 

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

func (*PushServiceOpaqueReceiver) XXX_DiscardUnknown 

func (m *PushServiceOpaqueReceiver) XXX_DiscardUnknown()

func (*PushServiceOpaqueReceiver) XXX_Marshal 

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

func (*PushServiceOpaqueReceiver) XXX_Merge 

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

func (*PushServiceOpaqueReceiver) XXX_Size 

func (m *PushServiceOpaqueReceiver) XXX_Size() int

func (*PushServiceOpaqueReceiver) XXX_Unmarshal 

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

type PushServicePriority 

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

func (PushServicePriority) EnumDescriptor 

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

func (PushServicePriority) String 

func (x PushServicePriority) String() string

type 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 (m *PushServiceSend_Request) GetPriority() PushServicePriority

func (*PushServiceSend_Request) GetReceivers 

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

func (*PushServiceSend_Request) Marshal 

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

func (*PushServiceSend_Request) MarshalTo 

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

func (*PushServiceSend_Request) MarshalToSizedBuffer 

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

func (*PushServiceSend_Request) ProtoMessage 

func (*PushServiceSend_Request) ProtoMessage()

func (*PushServiceSend_Request) Reset 

func (m *PushServiceSend_Request) Reset()

func (*PushServiceSend_Request) Size 

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

func (*PushServiceSend_Request) String 

func (m *PushServiceSend_Request) String() string

func (*PushServiceSend_Request) Unmarshal 

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

func (*PushServiceSend_Request) XXX_DiscardUnknown 

func (m *PushServiceSend_Request) XXX_DiscardUnknown()

func (*PushServiceSend_Request) XXX_Marshal 

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

func (*PushServiceSend_Request) XXX_Merge 

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

func (*PushServiceSend_Request) XXX_Size 

func (m *PushServiceSend_Request) XXX_Size() int

func (*PushServiceSend_Request) XXX_Unmarshal 

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

type PushServiceServer 

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

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

type PushServiceServerInfo 

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

func (*PushServiceServerInfo) Descriptor 

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

func (*PushServiceServerInfo) Marshal 

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

func (*PushServiceServerInfo) MarshalTo 

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

func (*PushServiceServerInfo) MarshalToSizedBuffer 

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

func (*PushServiceServerInfo) ProtoMessage 

func (*PushServiceServerInfo) ProtoMessage()

func (*PushServiceServerInfo) Reset 

func (m *PushServiceServerInfo) Reset()

func (*PushServiceServerInfo) Size 

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

func (*PushServiceServerInfo) String 

func (m *PushServiceServerInfo) String() string

func (*PushServiceServerInfo) Unmarshal 

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

func (*PushServiceServerInfo) XXX_DiscardUnknown 

func (m *PushServiceServerInfo) XXX_DiscardUnknown()

func (*PushServiceServerInfo) XXX_Marshal 

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

func (*PushServiceServerInfo) XXX_Merge 

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

func (*PushServiceServerInfo) XXX_Size 

func (m *PushServiceServerInfo) XXX_Size() int

func (*PushServiceServerInfo) XXX_Unmarshal 

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

type PushServiceServerInfo_Reply 

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

func (*PushServiceServerInfo_Reply) Descriptor 

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

func (*PushServiceServerInfo_Reply) GetPublicKey 

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

func (*PushServiceServerInfo_Reply) GetSupportedTokenTypes 

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

func (*PushServiceServerInfo_Reply) Marshal 

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

func (*PushServiceServerInfo_Reply) MarshalTo 

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

func (*PushServiceServerInfo_Reply) MarshalToSizedBuffer 

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

func (*PushServiceServerInfo_Reply) ProtoMessage 

func (*PushServiceServerInfo_Reply) ProtoMessage()

func (*PushServiceServerInfo_Reply) Reset 

func (m *PushServiceServerInfo_Reply) Reset()

func (*PushServiceServerInfo_Reply) Size 

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

func (*PushServiceServerInfo_Reply) String 

func (m *PushServiceServerInfo_Reply) String() string

func (*PushServiceServerInfo_Reply) Unmarshal 

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

func (*PushServiceServerInfo_Reply) XXX_DiscardUnknown 

func (m *PushServiceServerInfo_Reply) XXX_DiscardUnknown()

func (*PushServiceServerInfo_Reply) XXX_Marshal 

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

func (*PushServiceServerInfo_Reply) XXX_Merge 

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

func (*PushServiceServerInfo_Reply) XXX_Size 

func (m *PushServiceServerInfo_Reply) XXX_Size() int

func (*PushServiceServerInfo_Reply) XXX_Unmarshal 

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

type PushServiceServerInfo_Request 

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

func (*PushServiceServerInfo_Request) Descriptor 

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

func (*PushServiceServerInfo_Request) Marshal 

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

func (*PushServiceServerInfo_Request) MarshalTo 

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

func (*PushServiceServerInfo_Request) MarshalToSizedBuffer 

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

func (*PushServiceServerInfo_Request) ProtoMessage 

func (*PushServiceServerInfo_Request) ProtoMessage()

func (*PushServiceServerInfo_Request) Reset 

func (m *PushServiceServerInfo_Request) Reset()

func (*PushServiceServerInfo_Request) Size 

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

func (*PushServiceServerInfo_Request) String 

func (m *PushServiceServerInfo_Request) String() string

func (*PushServiceServerInfo_Request) Unmarshal 

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

func (*PushServiceServerInfo_Request) XXX_DiscardUnknown 

func (m *PushServiceServerInfo_Request) XXX_DiscardUnknown()

func (*PushServiceServerInfo_Request) XXX_Marshal 

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

func (*PushServiceServerInfo_Request) XXX_Merge 

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

func (*PushServiceServerInfo_Request) XXX_Size 

func (m *PushServiceServerInfo_Request) XXX_Size() int

func (*PushServiceServerInfo_Request) XXX_Unmarshal 

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

type PushServiceSupportedTokenType 

type PushServiceSupportedTokenType struct {
	AppBundleID          string               `protobuf:"bytes,1,opt,name=app_bundle_id,json=appBundleId,proto3" json:"app_bundle_id,omitempty"`
	TokenType            PushServiceTokenType `` /* 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 must be embedded to have forward compatible implementations.

func (UnimplementedPushServiceServer) Send 

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

func (UnimplementedPushServiceServer) ServerInfo 

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

type UnsafePushServiceServer 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.

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.