shared

package
v0.0.12 Latest Latest
Warning

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

 Go to latest Published: Nov 12, 2019 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var RuntimeInfoReport_HealthStatus_name = map[int32]string{
	0: "SICK",
	1: "RUNNING",
	2: "BOOTSTRAP",
	3: "PARTIAL_STOP",
}
View Source 
var RuntimeInfoReport_HealthStatus_value = map[string]int32{
	"SICK":         0,
	"RUNNING":      1,
	"BOOTSTRAP":    2,
	"PARTIAL_STOP": 3,
}

Functions

This section is empty.

Types

type RuntimeInfoReport 

type RuntimeInfoReport struct {
	PeerId               []byte                         `protobuf:"bytes,1,opt,name=peer_id,json=peerId,proto3" json:"peer_id,omitempty"`
	Address              []byte                         `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	ServiceName          []byte                         `protobuf:"bytes,3,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	Status               RuntimeInfoReport_HealthStatus `protobuf:"varint,4,opt,name=status,proto3,enum=shared.RuntimeInfoReport_HealthStatus" json:"status,omitempty"`
	CurentTime           *time.Time                     `protobuf:"bytes,5,opt,name=curent_time,json=curentTime,proto3,stdtime" json:"curent_time,omitempty"`
	StartTime            *time.Time                     `protobuf:"bytes,6,opt,name=start_time,json=startTime,proto3,stdtime" json:"start_time,omitempty"`
	GitHash              []byte                         `protobuf:"bytes,7,opt,name=git_hash,json=gitHash,proto3" json:"git_hash,omitempty"`
	Version              []byte                         `protobuf:"bytes,8,opt,name=version,proto3" json:"version,omitempty"`
	DbStatusExtra        []byte                         `protobuf:"bytes,9,opt,name=db_status_extra,json=dbStatusExtra,proto3" json:"db_status_extra,omitempty"`
	QueueStatusExtra     []byte                         `protobuf:"bytes,10,opt,name=queue_status_extra,json=queueStatusExtra,proto3" json:"queue_status_extra,omitempty"`
	ChainStatusExtra     []byte                         `protobuf:"bytes,11,opt,name=chain_status_extra,json=chainStatusExtra,proto3" json:"chain_status_extra,omitempty"`
	CacheStatusExtra     []byte                         `protobuf:"bytes,12,opt,name=cache_status_extra,json=cacheStatusExtra,proto3" json:"cache_status_extra,omitempty"`
	Extra                []byte                         `protobuf:"bytes,13,opt,name=extra,proto3" json:"extra,omitempty"`
	Signature            []byte                         `protobuf:"bytes,14,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

func (*RuntimeInfoReport) Descriptor 

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

func (*RuntimeInfoReport) GetAddress 

func (m *RuntimeInfoReport) GetAddress() []byte

func (*RuntimeInfoReport) GetCacheStatusExtra 

func (m *RuntimeInfoReport) GetCacheStatusExtra() []byte

func (*RuntimeInfoReport) GetChainStatusExtra 

func (m *RuntimeInfoReport) GetChainStatusExtra() []byte

func (*RuntimeInfoReport) GetCurentTime 

func (m *RuntimeInfoReport) GetCurentTime() *time.Time

func (*RuntimeInfoReport) GetDbStatusExtra 

func (m *RuntimeInfoReport) GetDbStatusExtra() []byte

func (*RuntimeInfoReport) GetExtra 

func (m *RuntimeInfoReport) GetExtra() []byte

func (*RuntimeInfoReport) GetGitHash 

func (m *RuntimeInfoReport) GetGitHash() []byte

func (*RuntimeInfoReport) GetPeerId 

func (m *RuntimeInfoReport) GetPeerId() []byte

func (*RuntimeInfoReport) GetQueueStatusExtra 

func (m *RuntimeInfoReport) GetQueueStatusExtra() []byte

func (*RuntimeInfoReport) GetServiceName 

func (m *RuntimeInfoReport) GetServiceName() []byte

func (*RuntimeInfoReport) GetSignature 

func (m *RuntimeInfoReport) GetSignature() []byte

func (*RuntimeInfoReport) GetStartTime 

func (m *RuntimeInfoReport) GetStartTime() *time.Time

func (*RuntimeInfoReport) GetStatus 

func (m *RuntimeInfoReport) GetStatus() RuntimeInfoReport_HealthStatus

func (*RuntimeInfoReport) GetVersion 

func (m *RuntimeInfoReport) GetVersion() []byte

func (*RuntimeInfoReport) ProtoMessage 

func (*RuntimeInfoReport) ProtoMessage()

func (*RuntimeInfoReport) Reset 

func (m *RuntimeInfoReport) Reset()

func (*RuntimeInfoReport) String 

func (m *RuntimeInfoReport) String() string

func (*RuntimeInfoReport) XXX_DiscardUnknown 

func (m *RuntimeInfoReport) XXX_DiscardUnknown()

func (*RuntimeInfoReport) XXX_Marshal 

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

func (*RuntimeInfoReport) XXX_Merge 

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

func (*RuntimeInfoReport) XXX_Size 

func (m *RuntimeInfoReport) XXX_Size() int

func (*RuntimeInfoReport) XXX_Unmarshal 

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

type RuntimeInfoReport_HealthStatus 

type RuntimeInfoReport_HealthStatus int32
const (
	RuntimeInfoReport_SICK         RuntimeInfoReport_HealthStatus = 0
	RuntimeInfoReport_RUNNING      RuntimeInfoReport_HealthStatus = 1
	RuntimeInfoReport_BOOTSTRAP    RuntimeInfoReport_HealthStatus = 2
	RuntimeInfoReport_PARTIAL_STOP RuntimeInfoReport_HealthStatus = 3
)

func (RuntimeInfoReport_HealthStatus) EnumDescriptor 

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

func (RuntimeInfoReport_HealthStatus) String 

func (x RuntimeInfoReport_HealthStatus) String() string

type RuntimeInfoRequest 

type RuntimeInfoRequest struct {
	RequestAddress       []byte           `protobuf:"bytes,1,opt,name=request_address,json=requestAddress,proto3" json:"request_address,omitempty"`
	CurentTime           *types.Timestamp `protobuf:"bytes,2,opt,name=curent_time,json=curentTime,proto3" json:"curent_time,omitempty"`
	Signature            []byte           `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*RuntimeInfoRequest) Descriptor 

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

func (*RuntimeInfoRequest) GetCurentTime 

func (m *RuntimeInfoRequest) GetCurentTime() *types.Timestamp

func (*RuntimeInfoRequest) GetRequestAddress 

func (m *RuntimeInfoRequest) GetRequestAddress() []byte

func (*RuntimeInfoRequest) GetSignature 

func (m *RuntimeInfoRequest) GetSignature() []byte

func (*RuntimeInfoRequest) ProtoMessage 

func (*RuntimeInfoRequest) ProtoMessage()

func (*RuntimeInfoRequest) Reset 

func (m *RuntimeInfoRequest) Reset()

func (*RuntimeInfoRequest) String 

func (m *RuntimeInfoRequest) String() string

func (*RuntimeInfoRequest) XXX_DiscardUnknown 

func (m *RuntimeInfoRequest) XXX_DiscardUnknown()

func (*RuntimeInfoRequest) XXX_Marshal 

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

func (*RuntimeInfoRequest) XXX_Merge 

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

func (*RuntimeInfoRequest) XXX_Size 

func (m *RuntimeInfoRequest) XXX_Size() int

func (*RuntimeInfoRequest) XXX_Unmarshal 

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

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.