rpc

package
v0.0.0-...-d560322 Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var FailureKind_name = map[int32]string{
	0: "TEMPORARY_ERROR",
	1: "INVALID_TOKEN",
	2: "INVALID_PAYLOAD",
}
View Source 
var FailureKind_value = map[string]int32{
	"TEMPORARY_ERROR": 0,
	"INVALID_TOKEN":   1,
	"INVALID_PAYLOAD": 2,
}
View Source 
var Platform_name = map[int32]string{
	0: "UNKNOWN",
	1: "APNS",
	2: "GCM",

	3: "ALT",
	4: "WEBPUSH",
	5: "ADM",
}
View Source 
var Platform_value = map[string]int32{
	"UNKNOWN": 0,
	"APNS":    1,
	"GCM":     2,
	"FCM":     2,
	"ALT":     3,
	"WEBPUSH": 4,
	"ADM":     5,
}
View Source 
var Priority_name = map[int32]string{
	0: "HIGH",
	1: "NORMAL",
	2: "LOW",
	3: "VERY_LOW",
}
View Source 
var Priority_value = map[string]int32{
	"HIGH":     0,
	"NORMAL":   1,
	"LOW":      2,
	"VERY_LOW": 3,
}

Functions

func RegisterBoltzGatewayServer 

func RegisterBoltzGatewayServer(s *grpc.Server, srv BoltzGatewayServer)

Types

type BoltzGatewayClient 

type BoltzGatewayClient interface {
	// Send はMessageを各デバイスへ送信する。
	// トークン無効など対応の必要なEventが発生したらクライアントへ返す。
	Send(ctx context.Context, in *Message, opts ...grpc.CallOption) (BoltzGateway_SendClient, error)
	// FetchStatistics はmasterサービスと、masterから接続しているslaveの状態を返す。
	FetchStatistics(ctx context.Context, in *StatisticsQuery, opts ...grpc.CallOption) (*MasterStatistics, error)
	// APNsのフィードバックサービスから無効トークンを取得する。
	FetchFeedback(ctx context.Context, in *apns.Header, opts ...grpc.CallOption) (BoltzGateway_FetchFeedbackClient, error)
}

BoltzGatewayClient is the client API for BoltzGateway service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewBoltzGatewayClient 

func NewBoltzGatewayClient(cc *grpc.ClientConn) BoltzGatewayClient

type BoltzGatewayServer 

type BoltzGatewayServer interface {
	// Send はMessageを各デバイスへ送信する。
	// トークン無効など対応の必要なEventが発生したらクライアントへ返す。
	Send(*Message, BoltzGateway_SendServer) error
	// FetchStatistics はmasterサービスと、masterから接続しているslaveの状態を返す。
	FetchStatistics(context.Context, *StatisticsQuery) (*MasterStatistics, error)
	// APNsのフィードバックサービスから無効トークンを取得する。
	FetchFeedback(*apns.Header, BoltzGateway_FetchFeedbackServer) error
}

BoltzGatewayServer is the server API for BoltzGateway service.

type BoltzGateway_FetchFeedbackClient 

type BoltzGateway_FetchFeedbackClient interface {
	Recv() (*UnavailableTokenEvent, error)
	grpc.ClientStream
}

type BoltzGateway_FetchFeedbackServer 

type BoltzGateway_FetchFeedbackServer interface {
	Send(*UnavailableTokenEvent) error
	grpc.ServerStream
}

type BoltzGateway_SendClient 

type BoltzGateway_SendClient interface {
	Recv() (*Event, error)
	grpc.ClientStream
}

type BoltzGateway_SendServer 

type BoltzGateway_SendServer interface {
	Send(*Event) error
	grpc.ServerStream
}

type DeliveryFailure 

type DeliveryFailure struct {
	Kind                 FailureKind `protobuf:"varint,1,opt,name=kind,proto3,enum=rpc.FailureKind" json:"kind,omitempty"`
	Token                string      `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Status               string      `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Timestamp            uint32      `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

DeliveryFailure は送信失敗したトークンと理由を表す。

func (*DeliveryFailure) Descriptor 

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

func (*DeliveryFailure) GetKind 

func (m *DeliveryFailure) GetKind() FailureKind

func (*DeliveryFailure) GetStatus 

func (m *DeliveryFailure) GetStatus() string

func (*DeliveryFailure) GetTimestamp 

func (m *DeliveryFailure) GetTimestamp() uint32

func (*DeliveryFailure) GetToken 

func (m *DeliveryFailure) GetToken() string

func (*DeliveryFailure) ProtoMessage 

func (*DeliveryFailure) ProtoMessage()

func (*DeliveryFailure) Reset 

func (m *DeliveryFailure) Reset()

func (*DeliveryFailure) String 

func (m *DeliveryFailure) String() string

func (*DeliveryFailure) XXX_DiscardUnknown 

func (m *DeliveryFailure) XXX_DiscardUnknown()

func (*DeliveryFailure) XXX_Marshal 

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

func (*DeliveryFailure) XXX_Merge 

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

func (*DeliveryFailure) XXX_Size 

func (m *DeliveryFailure) XXX_Size() int

func (*DeliveryFailure) XXX_Unmarshal 

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

type Event 

type Event struct {
	// イベントが発生したプラットフォーム
	Platform Platform `protobuf:"varint,1,opt,name=platform,proto3,enum=rpc.Platform" json:"platform,omitempty"`
	// イベント発生の理由
	//
	// Types that are valid to be assigned to Event:
	//	*Event_Failed
	//	*Event_Renewed
	Event                isEvent_Event `protobuf_oneof:"event"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Event は確認が必要なイベントを表す。

func (*Event) Descriptor 

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

func (*Event) GetEvent 

func (m *Event) GetEvent() isEvent_Event

func (*Event) GetFailed 

func (m *Event) GetFailed() *DeliveryFailure

func (*Event) GetPlatform 

func (m *Event) GetPlatform() Platform

func (*Event) GetRenewed 

func (m *Event) GetRenewed() *TokenRenewal

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_OneofWrappers 

func (*Event) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type Event_Failed 

type Event_Failed struct {
	Failed *DeliveryFailure `protobuf:"bytes,2,opt,name=failed,proto3,oneof"`
}

type Event_Renewed 

type Event_Renewed struct {
	Renewed *TokenRenewal `protobuf:"bytes,3,opt,name=renewed,proto3,oneof"`
}

type FailureKind 

type FailureKind int32

FailureKind は送信失敗の理由を表す。 

const (
	// 通信不能等の一時的なエラー(再送すれば届く可能性がある)
	FailureKind_TEMPORARY_ERROR FailureKind = 0
	// 無効なトークンなので次からは使うべきではない
	FailureKind_INVALID_TOKEN FailureKind = 1
	// 不正なメッセージのため送信したメッセージの確認すること
	FailureKind_INVALID_PAYLOAD FailureKind = 2
)

func (FailureKind) EnumDescriptor 

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

func (FailureKind) String 

func (x FailureKind) String() string

type MasterStatistics 

type MasterStatistics struct {
	Version       string            `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Compiler      string            `protobuf:"bytes,2,opt,name=compiler,proto3" json:"compiler,omitempty"`
	NumProcessor  int32             `protobuf:"varint,3,opt,name=numProcessor,proto3" json:"numProcessor,omitempty"`
	NumTask       int32             `protobuf:"varint,4,opt,name=numTask,proto3" json:"numTask,omitempty"`
	MemStatistics *MemoryStatistics `protobuf:"bytes,5,opt,name=memStatistics,proto3" json:"memStatistics,omitempty"`
	// スレーブに対して送信待ちしているリクエスト数
	NumPending int32 `protobuf:"varint,6,opt,name=numPending,proto3" json:"numPending,omitempty"`
	// アドレスをキーとする各スレーブの状態
	SlaveStatistics      map[string]*SlaveStatistics `` /* 171-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

MasterStatistics はBoltzEngineマスタの状態をあらわす。

func (*MasterStatistics) Descriptor 

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

func (*MasterStatistics) GetCompiler 

func (m *MasterStatistics) GetCompiler() string

func (*MasterStatistics) GetMemStatistics 

func (m *MasterStatistics) GetMemStatistics() *MemoryStatistics

func (*MasterStatistics) GetNumPending 

func (m *MasterStatistics) GetNumPending() int32

func (*MasterStatistics) GetNumProcessor 

func (m *MasterStatistics) GetNumProcessor() int32

func (*MasterStatistics) GetNumTask 

func (m *MasterStatistics) GetNumTask() int32

func (*MasterStatistics) GetSlaveStatistics 

func (m *MasterStatistics) GetSlaveStatistics() map[string]*SlaveStatistics

func (*MasterStatistics) GetVersion 

func (m *MasterStatistics) GetVersion() string

func (*MasterStatistics) ProtoMessage 

func (*MasterStatistics) ProtoMessage()

func (*MasterStatistics) Reset 

func (m *MasterStatistics) Reset()

func (*MasterStatistics) String 

func (m *MasterStatistics) String() string

func (*MasterStatistics) XXX_DiscardUnknown 

func (m *MasterStatistics) XXX_DiscardUnknown()

func (*MasterStatistics) XXX_Marshal 

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

func (*MasterStatistics) XXX_Merge 

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

func (*MasterStatistics) XXX_Size 

func (m *MasterStatistics) XXX_Size() int

func (*MasterStatistics) XXX_Unmarshal 

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

type MemoryStatistics 

type MemoryStatistics struct {
	// 割り当てられているメモリ容量
	Alloc uint64 `protobuf:"varint,1,opt,name=alloc,proto3" json:"alloc,omitempty"`
	// 割り当てたメモリ容量
	TotalAlloc uint64 `protobuf:"varint,2,opt,name=totalAlloc,proto3" json:"totalAlloc,omitempty"`
	// システムに確保されたメモリ容量
	Sys uint64 `protobuf:"varint,3,opt,name=sys,proto3" json:"sys,omitempty"`
	// mallocによりメモリを割り当てた回数
	Mallocs uint64 `protobuf:"varint,4,opt,name=mallocs,proto3" json:"mallocs,omitempty"`
	// freeした回数
	Frees uint64 `protobuf:"varint,5,opt,name=frees,proto3" json:"frees,omitempty"`
	// ヒープに割り当てられているメモリ容量
	HeapAlloc uint64 `protobuf:"varint,6,opt,name=heapAlloc,proto3" json:"heapAlloc,omitempty"`
	// システムに確保されたメモリ容量(ヒープ)
	HeapSys uint64 `protobuf:"varint,7,opt,name=heapSys,proto3" json:"heapSys,omitempty"`
	// ヒープにあるオブジェクト数
	HeapObjects          uint64   `protobuf:"varint,8,opt,name=heapObjects,proto3" json:"heapObjects,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

MemoryStatistics はサーバのメモリ状況をあらわす。

func (*MemoryStatistics) Descriptor 

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

func (*MemoryStatistics) GetAlloc 

func (m *MemoryStatistics) GetAlloc() uint64

func (*MemoryStatistics) GetFrees 

func (m *MemoryStatistics) GetFrees() uint64

func (*MemoryStatistics) GetHeapAlloc 

func (m *MemoryStatistics) GetHeapAlloc() uint64

func (*MemoryStatistics) GetHeapObjects 

func (m *MemoryStatistics) GetHeapObjects() uint64

func (*MemoryStatistics) GetHeapSys 

func (m *MemoryStatistics) GetHeapSys() uint64

func (*MemoryStatistics) GetMallocs 

func (m *MemoryStatistics) GetMallocs() uint64

func (*MemoryStatistics) GetSys 

func (m *MemoryStatistics) GetSys() uint64

func (*MemoryStatistics) GetTotalAlloc 

func (m *MemoryStatistics) GetTotalAlloc() uint64

func (*MemoryStatistics) ProtoMessage 

func (*MemoryStatistics) ProtoMessage()

func (*MemoryStatistics) Reset 

func (m *MemoryStatistics) Reset()

func (*MemoryStatistics) String 

func (m *MemoryStatistics) String() string

func (*MemoryStatistics) XXX_DiscardUnknown 

func (m *MemoryStatistics) XXX_DiscardUnknown()

func (*MemoryStatistics) XXX_Marshal 

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

func (*MemoryStatistics) XXX_Merge 

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

func (*MemoryStatistics) XXX_Size 

func (m *MemoryStatistics) XXX_Size() int

func (*MemoryStatistics) XXX_Unmarshal 

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

type Message 

type Message struct {
	// APNs固有の接続情報
	ApnsHeader *apns.Header `protobuf:"bytes,1,opt,name=apnsHeader,proto3" json:"apnsHeader,omitempty"`
	// FCM固有の接続情報
	GcmHeader *gcm.Header `protobuf:"bytes,2,opt,name=gcmHeader,proto3" json:"gcmHeader,omitempty"`
	// WebPush固有の接続情報
	WebpushHeader *webpush.Header `protobuf:"bytes,9,opt,name=webpushHeader,proto3" json:"webpushHeader,omitempty"`
	// ADM固有の接続情報
	AdmHeader *adm.Header `protobuf:"bytes,11,opt,name=admHeader,proto3" json:"admHeader,omitempty"`
	// 通知対象のデバイストークン
	// APNsの場合は["1" + (hexエンコードされたトークン)]
	// FCMの場合は["2" + (FCMの登録ID)]
	// WebPushの場合は["4" + {"v":1,"endpoint":"(WebPushエンドポイント)","p256dh":"(ブラウザ公開鍵)","auth":"(WebPush乱数)"}],
	// ADMの場合は["5" + (ADM登録ID)]
	Tokens []string `protobuf:"bytes,3,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// メッセージ配信の優先度
	// Priority未定義値の場合は各プラットフォームのデフォルトを使う
	Priority Priority `protobuf:"varint,4,opt,name=priority,proto3,enum=rpc.Priority" json:"priority,omitempty"`
	// メッセージ配信の有効期限
	Expiration uint32 `protobuf:"varint,5,opt,name=expiration,proto3" json:"expiration,omitempty"`
	// メッセージをまとめる文字列(URLセーフな文字を32文字まで)
	CollapseKey string `protobuf:"bytes,12,opt,name=collapseKey,proto3" json:"collapseKey,omitempty"`
	// APNsへ送るJSONペイロード(APNsトークンを含む場合は必須)
	// JSONのフォーマットはAppleのドキュメントを参照すること
	Payload string `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`
	// FCM/ADMへ送るパラメータ(FCM登録ID/ADM登録IDを含む場合は必須)
	// それぞれの意味はGoogleのドキュメントを参照すること
	Parameters *gcm.Parameters `protobuf:"bytes,7,opt,name=parameters,proto3" json:"parameters,omitempty"`
	// WebPushへ送るHTTP Body(WebPushトークンを含む場合は必須)
	// フォーマットは受信アプリの仕様に依存する
	Body string `protobuf:"bytes,10,opt,name=body,proto3" json:"body,omitempty"`
	// 1秒あたりの通知数(0以下なら無制限)
	BandWidth            int32    `protobuf:"varint,8,opt,name=bandWidth,proto3" json:"bandWidth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message はデバイスに通知するメッセージを表す。

func (*Message) Descriptor 

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

func (*Message) GetAdmHeader 

func (m *Message) GetAdmHeader() *adm.Header

func (*Message) GetApnsHeader 

func (m *Message) GetApnsHeader() *apns.Header

func (*Message) GetBandWidth 

func (m *Message) GetBandWidth() int32

func (*Message) GetBody 

func (m *Message) GetBody() string

func (*Message) GetCollapseKey 

func (m *Message) GetCollapseKey() string

func (*Message) GetExpiration 

func (m *Message) GetExpiration() uint32

func (*Message) GetGcmHeader 

func (m *Message) GetGcmHeader() *gcm.Header

func (*Message) GetParameters 

func (m *Message) GetParameters() *gcm.Parameters

func (*Message) GetPayload 

func (m *Message) GetPayload() string

func (*Message) GetPriority 

func (m *Message) GetPriority() Priority

func (*Message) GetTokens 

func (m *Message) GetTokens() []string

func (*Message) GetWebpushHeader 

func (m *Message) GetWebpushHeader() *webpush.Header

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type Platform 

type Platform int32

Platform は通知サービスを表す。 

const (
	Platform_UNKNOWN Platform = 0
	Platform_APNS    Platform = 1
	Platform_GCM     Platform = 2
	Platform_FCM     Platform = 2
	Platform_ALT     Platform = 3
	Platform_WEBPUSH Platform = 4
	Platform_ADM     Platform = 5
)

func (Platform) EnumDescriptor 

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

func (Platform) String 

func (x Platform) String() string

type Priority 

type Priority int32

Priority はメッセージの優先順位を表す。 

const (
	// 可能な限り早く、デバイスがスリープでも通知する。
	Priority_HIGH Priority = 0
	// バッテリ状況を考慮して通知する。
	// APNsのcontent-available通知はNORMALで送らなければならない。
	Priority_NORMAL Priority = 1
	// WebPushのみ; topic updateなど
	Priority_LOW Priority = 2
	// WebPushのみ; advertisementなど
	Priority_VERY_LOW Priority = 3
)

func (Priority) EnumDescriptor 

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

func (Priority) String 

func (x Priority) String() string

type SlaveStatistics 

type SlaveStatistics struct {
	// Goコンパイラのバージョン
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// Goコンパイラの名前
	Compiler string `protobuf:"bytes,2,opt,name=compiler,proto3" json:"compiler,omitempty"`
	// CPUコア数
	NumProcessor int32 `protobuf:"varint,3,opt,name=numProcessor,proto3" json:"numProcessor,omitempty"`
	// 実行中のゴルーチン数
	NumTask int32 `protobuf:"varint,4,opt,name=numTask,proto3" json:"numTask,omitempty"`
	// メモリ状態
	MemStatistics *MemoryStatistics `protobuf:"bytes,5,opt,name=memStatistics,proto3" json:"memStatistics,omitempty"`
	// マスタひとつにつき最大いくつの同時リクエストを許可するか
	MaxAgents int32 `protobuf:"varint,6,opt,name=maxAgents,proto3" json:"maxAgents,omitempty"`
	// リクエストされた数
	NumTotalRequest int32 `protobuf:"varint,7,opt,name=numTotalRequest,proto3" json:"numTotalRequest,omitempty"`
	// 現在送信中の端末数
	NumDelivering int32 `protobuf:"varint,8,opt,name=numDelivering,proto3" json:"numDelivering,omitempty"`
	// 送信した端末数
	NumDeliveredDevices int32 `protobuf:"varint,9,opt,name=numDeliveredDevices,proto3" json:"numDeliveredDevices,omitempty"`
	// リクエスト開始から終了までの合計時間(Duration)
	TotalExecutionTime int64 `protobuf:"varint,10,opt,name=totalExecutionTime,proto3" json:"totalExecutionTime,omitempty"`
	// 最新のリクエスト処理時間(Duration)
	LatestExecutionTime int64 `protobuf:"varint,11,opt,name=latestExecutionTime,proto3" json:"latestExecutionTime,omitempty"`
	// SlaveActivityが最後に更新された時間(Unix-time)
	LastUpdate int64 `protobuf:"varint,12,opt,name=lastUpdate,proto3" json:"lastUpdate,omitempty"`
	// リトライした数
	RetryCount           int32    `protobuf:"varint,13,opt,name=retryCount,proto3" json:"retryCount,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

SlaveStatistics はBoltzEngineスレーブの状態をあらわす。

func (*SlaveStatistics) Descriptor 

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

func (*SlaveStatistics) GetCompiler 

func (m *SlaveStatistics) GetCompiler() string

func (*SlaveStatistics) GetLastUpdate 

func (m *SlaveStatistics) GetLastUpdate() int64

func (*SlaveStatistics) GetLatestExecutionTime 

func (m *SlaveStatistics) GetLatestExecutionTime() int64

func (*SlaveStatistics) GetMaxAgents 

func (m *SlaveStatistics) GetMaxAgents() int32

func (*SlaveStatistics) GetMemStatistics 

func (m *SlaveStatistics) GetMemStatistics() *MemoryStatistics

func (*SlaveStatistics) GetNumDeliveredDevices 

func (m *SlaveStatistics) GetNumDeliveredDevices() int32

func (*SlaveStatistics) GetNumDelivering 

func (m *SlaveStatistics) GetNumDelivering() int32

func (*SlaveStatistics) GetNumProcessor 

func (m *SlaveStatistics) GetNumProcessor() int32

func (*SlaveStatistics) GetNumTask 

func (m *SlaveStatistics) GetNumTask() int32

func (*SlaveStatistics) GetNumTotalRequest 

func (m *SlaveStatistics) GetNumTotalRequest() int32

func (*SlaveStatistics) GetRetryCount 

func (m *SlaveStatistics) GetRetryCount() int32

func (*SlaveStatistics) GetTotalExecutionTime 

func (m *SlaveStatistics) GetTotalExecutionTime() int64

func (*SlaveStatistics) GetVersion 

func (m *SlaveStatistics) GetVersion() string

func (*SlaveStatistics) ProtoMessage 

func (*SlaveStatistics) ProtoMessage()

func (*SlaveStatistics) Reset 

func (m *SlaveStatistics) Reset()

func (*SlaveStatistics) String 

func (m *SlaveStatistics) String() string

func (*SlaveStatistics) XXX_DiscardUnknown 

func (m *SlaveStatistics) XXX_DiscardUnknown()

func (*SlaveStatistics) XXX_Marshal 

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

func (*SlaveStatistics) XXX_Merge 

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

func (*SlaveStatistics) XXX_Size 

func (m *SlaveStatistics) XXX_Size() int

func (*SlaveStatistics) XXX_Unmarshal 

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

type StatisticsQuery 

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

func (*StatisticsQuery) Descriptor 

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

func (*StatisticsQuery) ProtoMessage 

func (*StatisticsQuery) ProtoMessage()

func (*StatisticsQuery) Reset 

func (m *StatisticsQuery) Reset()

func (*StatisticsQuery) String 

func (m *StatisticsQuery) String() string

func (*StatisticsQuery) XXX_DiscardUnknown 

func (m *StatisticsQuery) XXX_DiscardUnknown()

func (*StatisticsQuery) XXX_Marshal 

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

func (*StatisticsQuery) XXX_Merge 

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

func (*StatisticsQuery) XXX_Size 

func (m *StatisticsQuery) XXX_Size() int

func (*StatisticsQuery) XXX_Unmarshal 

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

type TokenRenewal 

type TokenRenewal struct {
	// 送信に使ったトークン
	RecentToken string `protobuf:"bytes,1,opt,name=recentToken,proto3" json:"recentToken,omitempty"`
	// 新しいトークン
	LatestToken          string   `protobuf:"bytes,2,opt,name=latestToken,proto3" json:"latestToken,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TokenRenewal はプラットフォーム側でのトークン変更を表す。

func (*TokenRenewal) Descriptor 

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

func (*TokenRenewal) GetLatestToken 

func (m *TokenRenewal) GetLatestToken() string

func (*TokenRenewal) GetRecentToken 

func (m *TokenRenewal) GetRecentToken() string

func (*TokenRenewal) ProtoMessage 

func (*TokenRenewal) ProtoMessage()

func (*TokenRenewal) Reset 

func (m *TokenRenewal) Reset()

func (*TokenRenewal) String 

func (m *TokenRenewal) String() string

func (*TokenRenewal) XXX_DiscardUnknown 

func (m *TokenRenewal) XXX_DiscardUnknown()

func (*TokenRenewal) XXX_Marshal 

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

func (*TokenRenewal) XXX_Merge 

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

func (*TokenRenewal) XXX_Size 

func (m *TokenRenewal) XXX_Size() int

func (*TokenRenewal) XXX_Unmarshal 

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

type UnavailableTokenEvent 

type UnavailableTokenEvent struct {
	// 無効と判断された時間(Unix-time)
	Timestamp uint32 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// 無効トークン
	Token                string   `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

UnavailableTokenEvent はアンインストール扱いのトークンをあらわす。

func (*UnavailableTokenEvent) Descriptor 

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

func (*UnavailableTokenEvent) GetTimestamp 

func (m *UnavailableTokenEvent) GetTimestamp() uint32

func (*UnavailableTokenEvent) GetToken 

func (m *UnavailableTokenEvent) GetToken() string

func (*UnavailableTokenEvent) ProtoMessage 

func (*UnavailableTokenEvent) ProtoMessage()

func (*UnavailableTokenEvent) Reset 

func (m *UnavailableTokenEvent) Reset()

func (*UnavailableTokenEvent) String 

func (m *UnavailableTokenEvent) String() string

func (*UnavailableTokenEvent) XXX_DiscardUnknown 

func (m *UnavailableTokenEvent) XXX_DiscardUnknown()

func (*UnavailableTokenEvent) XXX_Marshal 

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

func (*UnavailableTokenEvent) XXX_Merge 

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

func (*UnavailableTokenEvent) XXX_Size 

func (m *UnavailableTokenEvent) XXX_Size() int

func (*UnavailableTokenEvent) XXX_Unmarshal 

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

type UnimplementedBoltzGatewayServer 

type UnimplementedBoltzGatewayServer struct {
}

UnimplementedBoltzGatewayServer can be embedded to have forward compatible implementations.

func (*UnimplementedBoltzGatewayServer) FetchFeedback 

func (*UnimplementedBoltzGatewayServer) FetchFeedback(req *apns.Header, srv BoltzGateway_FetchFeedbackServer) error

func (*UnimplementedBoltzGatewayServer) FetchStatistics 

func (*UnimplementedBoltzGatewayServer) FetchStatistics(ctx context.Context, req *StatisticsQuery) (*MasterStatistics, error)

func (*UnimplementedBoltzGatewayServer) Send 

func (*UnimplementedBoltzGatewayServer) Send(req *Message, srv BoltzGateway_SendServer) error

Source Files

View all Source files

Directories

Path Synopsis

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.