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

                                func (*UnimplementedBoltzGatewayServer) Send

                                Source Files

                                Directories

                                Path Synopsis