pusherpb

Documentation

Overview

Package pusherpb is a generated protocol buffer package.

Pusher API

It is generated from these files:

pusher_service.proto

It has these top-level messages:

Status
PushRequest
PushResponse
PushSettingsRequest
PushSettingsResponse

Index

• Variables
• func RegisterPusherServiceHandlers(s *tcprpc.Server, prefix string, srv PusherServiceInterface)
• func RegisterSettingsPusherServiceHandlers(s *tcprpc.Server, prefix string, srv SettingsPusherServiceInterface)
• type PushCode
  • func (PushCode) EnumDescriptor() ([]byte, []int)
  • func (x PushCode) String() string
• type PushRequest
  • func (*PushRequest) Descriptor() ([]byte, []int)
  • func (m *PushRequest) GetTxns() []*chain.Txn
  • func (*PushRequest) ProtoMessage()
  • func (m *PushRequest) Reset()
  • func (m *PushRequest) String() string
• type PushResponse
  • func (*PushResponse) Descriptor() ([]byte, []int)
  • func (m *PushResponse) GetStatus() *Status
  • func (*PushResponse) ProtoMessage()
  • func (m *PushResponse) Reset()
  • func (m *PushResponse) String() string
• type PushSettingsRequest
  • func (*PushSettingsRequest) Descriptor() ([]byte, []int)
  • func (m *PushSettingsRequest) GetSettings() []*chain.Settings
  • func (*PushSettingsRequest) ProtoMessage()
  • func (m *PushSettingsRequest) Reset()
  • func (m *PushSettingsRequest) String() string
• type PushSettingsResponse
  • func (*PushSettingsResponse) Descriptor() ([]byte, []int)
  • func (m *PushSettingsResponse) GetStatus() *Status
  • func (*PushSettingsResponse) ProtoMessage()
  • func (m *PushSettingsResponse) Reset()
  • func (m *PushSettingsResponse) String() string
• type PusherServiceInterface
• type SettingsPusherServiceInterface
• type Status
  • func (*Status) Descriptor() ([]byte, []int)
  • func (m *Status) GetCode() int32
  • func (m *Status) GetMessage() string
  • func (*Status) ProtoMessage()
  • func (m *Status) Reset()
  • func (m *Status) String() string
• type TCPRPCPusherServiceClient
  • func NewTCPRPCPusherServiceClient(cl *tcprpc.Client, pref string) TCPRPCPusherServiceClient
  • func (cl TCPRPCPusherServiceClient) Push(ctx context.Context, args *PushRequest) (*PushResponse, error)
• type TCPRPCSettingsPusherServiceClient
  • func NewTCPRPCSettingsPusherServiceClient(cl *tcprpc.Client, pref string) TCPRPCSettingsPusherServiceClient
  • func (cl TCPRPCSettingsPusherServiceClient) PushSettings(ctx context.Context, args *PushSettingsRequest) (*PushSettingsResponse, error)

Variables

var PushCode_name = map[int32]string{
	0: "OK",
	1: "INTERNAL_ERROR",
}

var PushCode_value = map[string]int32{
	"OK":             0,
	"INTERNAL_ERROR": 1,
}

Functions

func RegisterPusherServiceHandlers

func RegisterPusherServiceHandlers(s *tcprpc.Server, prefix string, srv PusherServiceInterface)

func RegisterSettingsPusherServiceHandlers

func RegisterSettingsPusherServiceHandlers(s *tcprpc.Server, prefix string, srv SettingsPusherServiceInterface)

Types

type PushCode

type PushCode int32

const (
	PushCode_OK             PushCode = 0
	PushCode_INTERNAL_ERROR PushCode = 1
)

func (PushCode) EnumDescriptor

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

func (PushCode) String

func (x PushCode) String() string

type PushRequest

type PushRequest struct {
	Txns []*chain.Txn `protobuf:"bytes,1,rep,name=txns" json:"txns,omitempty"`
}

func (*PushRequest) Descriptor

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

func (*PushRequest) GetTxns

func (m *PushRequest) GetTxns() []*chain.Txn

func (*PushRequest) ProtoMessage

func (*PushRequest) ProtoMessage()

func (*PushRequest) Reset

func (m *PushRequest) Reset()

func (*PushRequest) String

func (m *PushRequest) String() string

type PushResponse

type PushResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}

func (*PushResponse) Descriptor

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

func (*PushResponse) GetStatus

func (m *PushResponse) GetStatus() *Status

func (*PushResponse) ProtoMessage

func (*PushResponse) ProtoMessage()

func (*PushResponse) Reset

func (m *PushResponse) Reset()

func (*PushResponse) String

func (m *PushResponse) String() string

type PushSettingsRequest

type PushSettingsRequest struct {
	Settings []*chain.Settings `protobuf:"bytes,1,rep,name=settings" json:"settings,omitempty"`
}

func (*PushSettingsRequest) Descriptor

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

func (*PushSettingsRequest) GetSettings

func (m *PushSettingsRequest) GetSettings() []*chain.Settings

func (*PushSettingsRequest) ProtoMessage

func (*PushSettingsRequest) ProtoMessage()

func (*PushSettingsRequest) Reset

func (m *PushSettingsRequest) Reset()

func (*PushSettingsRequest) String

func (m *PushSettingsRequest) String() string

type PushSettingsResponse

type PushSettingsResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
}

func (*PushSettingsResponse) Descriptor

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

func (*PushSettingsResponse) GetStatus

func (m *PushSettingsResponse) GetStatus() *Status

func (*PushSettingsResponse) ProtoMessage

func (*PushSettingsResponse) ProtoMessage()

func (*PushSettingsResponse) Reset

func (m *PushSettingsResponse) Reset()

func (*PushSettingsResponse) String

func (m *PushSettingsResponse) String() string

type PusherServiceInterface

type PusherServiceInterface interface {
	Push(context.Context, *PushRequest) (*PushResponse, error)
}

type SettingsPusherServiceInterface

type SettingsPusherServiceInterface interface {
	PushSettings(context.Context, *PushSettingsRequest) (*PushSettingsResponse, error)
}

type Status

type Status struct {
	// A simple error code that can be easily handled by the client.
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// A developer-facing human-readable error message in English. It should
	// both explain the error and offer an actionable resolution to it.
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*Status) Descriptor

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

func (*Status) GetCode

func (m *Status) GetCode() int32

func (*Status) GetMessage

func (m *Status) GetMessage() string

func (*Status) ProtoMessage

func (*Status) ProtoMessage()

func (*Status) Reset

func (m *Status) Reset()

func (*Status) String

func (m *Status) String() string

type TCPRPCPusherServiceClient

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

func NewTCPRPCPusherServiceClient

func NewTCPRPCPusherServiceClient(cl *tcprpc.Client, pref string) TCPRPCPusherServiceClient

func (TCPRPCPusherServiceClient) Push

func (cl TCPRPCPusherServiceClient) Push(ctx context.Context, args *PushRequest) (*PushResponse, error)

type TCPRPCSettingsPusherServiceClient

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

func NewTCPRPCSettingsPusherServiceClient

func NewTCPRPCSettingsPusherServiceClient(cl *tcprpc.Client, pref string) TCPRPCSettingsPusherServiceClient

func (TCPRPCSettingsPusherServiceClient) PushSettings

func (cl TCPRPCSettingsPusherServiceClient) PushSettings(ctx context.Context, args *PushSettingsRequest) (*PushSettingsResponse, error)