status

package
v0.0.0-...-4b7bac6 Latest Latest
Warning

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

 Go to latest Published: May 10, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_status_proto protoreflect.FileDescriptor
View Source 
var File_sync_proto protoreflect.FileDescriptor

Functions

func RegisterMaintainerServer 

func RegisterMaintainerServer(s *grpc.Server, srv MaintainerServer)

func RegisterSyncServer 

func RegisterSyncServer(s *grpc.Server, srv SyncServer)

Types

type InvalidReply 

type InvalidReply struct {
	Token string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	// contains filtered or unexported fields
}

func (*InvalidReply) Descriptor deprecated 

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

Deprecated: Use InvalidReply.ProtoReflect.Descriptor instead.

func (*InvalidReply) GetToken 

func (x *InvalidReply) GetToken() string

func (*InvalidReply) ProtoMessage 

func (*InvalidReply) ProtoMessage()

func (*InvalidReply) ProtoReflect 

func (x *InvalidReply) ProtoReflect() protoreflect.Message

func (*InvalidReply) Reset 

func (x *InvalidReply) Reset()

func (*InvalidReply) String 

func (x *InvalidReply) String() string

type InvalidRequest 

type InvalidRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Token string `protobuf:"bytes,2,opt,name=Token,proto3" json:"Token,omitempty"`
	// contains filtered or unexported fields
}

func (*InvalidRequest) Descriptor deprecated 

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

Deprecated: Use InvalidRequest.ProtoReflect.Descriptor instead.

func (*InvalidRequest) GetName 

func (x *InvalidRequest) GetName() string

func (*InvalidRequest) GetToken 

func (x *InvalidRequest) GetToken() string

func (*InvalidRequest) ProtoMessage 

func (*InvalidRequest) ProtoMessage()

func (*InvalidRequest) ProtoReflect 

func (x *InvalidRequest) ProtoReflect() protoreflect.Message

func (*InvalidRequest) Reset 

func (x *InvalidRequest) Reset()

func (*InvalidRequest) String 

func (x *InvalidRequest) String() string

type MaintainerClient 

type MaintainerClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterReply, error)
	ChangeStatus(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusReply, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryReply, error)
	Invalid(ctx context.Context, opts ...grpc.CallOption) (Maintainer_InvalidClient, error)
}

MaintainerClient is the client API for Maintainer service.

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

func NewMaintainerClient 

func NewMaintainerClient(cc grpc.ClientConnInterface) MaintainerClient

type MaintainerServer 

type MaintainerServer interface {
	Register(context.Context, *RegisterRequest) (*RegisterReply, error)
	ChangeStatus(context.Context, *StatusRequest) (*StatusReply, error)
	Query(context.Context, *QueryRequest) (*QueryReply, error)
	Invalid(Maintainer_InvalidServer) error
}

MaintainerServer is the server API for Maintainer service.

type Maintainer_InvalidClient 

type Maintainer_InvalidClient interface {
	Send(*InvalidRequest) error
	Recv() (*InvalidReply, error)
	grpc.ClientStream
}

type Maintainer_InvalidServer 

type Maintainer_InvalidServer interface {
	Send(*InvalidReply) error
	Recv() (*InvalidRequest, error)
	grpc.ServerStream
}

type QueryReply 

type QueryReply struct {
	Token   string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	Host    string `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	Version uint64 `protobuf:"varint,3,opt,name=Version,proto3" json:"Version,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryReply) Descriptor deprecated 

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

Deprecated: Use QueryReply.ProtoReflect.Descriptor instead.

func (*QueryReply) GetHost 

func (x *QueryReply) GetHost() string

func (*QueryReply) GetToken 

func (x *QueryReply) GetToken() string

func (*QueryReply) GetVersion 

func (x *QueryReply) GetVersion() uint64

func (*QueryReply) ProtoMessage 

func (*QueryReply) ProtoMessage()

func (*QueryReply) ProtoReflect 

func (x *QueryReply) ProtoReflect() protoreflect.Message

func (*QueryReply) Reset 

func (x *QueryReply) Reset()

func (*QueryReply) String 

func (x *QueryReply) String() string

type QueryRequest 

type QueryRequest struct {
	Token string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetToken 

func (x *QueryRequest) GetToken() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

func (x *QueryRequest) ProtoReflect() protoreflect.Message

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type RegisterReply 

type RegisterReply struct {
	Code int32  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterReply) Descriptor deprecated 

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

Deprecated: Use RegisterReply.ProtoReflect.Descriptor instead.

func (*RegisterReply) GetCode 

func (x *RegisterReply) GetCode() int32

func (*RegisterReply) GetMsg 

func (x *RegisterReply) GetMsg() string

func (*RegisterReply) ProtoMessage 

func (*RegisterReply) ProtoMessage()

func (*RegisterReply) ProtoReflect 

func (x *RegisterReply) ProtoReflect() protoreflect.Message

func (*RegisterReply) Reset 

func (x *RegisterReply) Reset()

func (*RegisterReply) String 

func (x *RegisterReply) String() string

type RegisterRequest 

type RegisterRequest struct {
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Host string `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetHost 

func (x *RegisterRequest) GetHost() string

func (*RegisterRequest) GetName 

func (x *RegisterRequest) GetName() string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

func (x *RegisterRequest) ProtoReflect() protoreflect.Message

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type StatusReply 

type StatusReply struct {
	Token   string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	Host    string `protobuf:"bytes,2,opt,name=Host,proto3" json:"Host,omitempty"`
	Version uint64 `protobuf:"varint,3,opt,name=Version,proto3" json:"Version,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusReply) Descriptor deprecated 

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

Deprecated: Use StatusReply.ProtoReflect.Descriptor instead.

func (*StatusReply) GetHost 

func (x *StatusReply) GetHost() string

func (*StatusReply) GetToken 

func (x *StatusReply) GetToken() string

func (*StatusReply) GetVersion 

func (x *StatusReply) GetVersion() uint64

func (*StatusReply) ProtoMessage 

func (*StatusReply) ProtoMessage()

func (*StatusReply) ProtoReflect 

func (x *StatusReply) ProtoReflect() protoreflect.Message

func (*StatusReply) Reset 

func (x *StatusReply) Reset()

func (*StatusReply) String 

func (x *StatusReply) String() string

type StatusRequest 

type StatusRequest struct {
	Token string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetName 

func (x *StatusRequest) GetName() string

func (*StatusRequest) GetToken 

func (x *StatusRequest) GetToken() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

func (x *StatusRequest) ProtoReflect() protoreflect.Message

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type SyncClient 

type SyncClient interface {
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncReply, error)
}

SyncClient is the client API for Sync service.

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

func NewSyncClient 

func NewSyncClient(cc grpc.ClientConnInterface) SyncClient

type SyncReply 

type SyncReply struct {
	Value string `protobuf:"bytes,1,opt,name=Value,proto3" json:"Value,omitempty"`
	Code  int32  `protobuf:"varint,2,opt,name=Code,proto3" json:"Code,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncReply) Descriptor deprecated 

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

Deprecated: Use SyncReply.ProtoReflect.Descriptor instead.

func (*SyncReply) GetCode 

func (x *SyncReply) GetCode() int32

func (*SyncReply) GetValue 

func (x *SyncReply) GetValue() string

func (*SyncReply) ProtoMessage 

func (*SyncReply) ProtoMessage()

func (*SyncReply) ProtoReflect 

func (x *SyncReply) ProtoReflect() protoreflect.Message

func (*SyncReply) Reset 

func (x *SyncReply) Reset()

func (*SyncReply) String 

func (x *SyncReply) String() string

type SyncRequest 

type SyncRequest struct {
	Token string `protobuf:"bytes,1,opt,name=Token,proto3" json:"Token,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncRequest) Descriptor deprecated 

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

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) GetToken 

func (x *SyncRequest) GetToken() string

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect 

func (x *SyncRequest) ProtoReflect() protoreflect.Message

func (*SyncRequest) Reset 

func (x *SyncRequest) Reset()

func (*SyncRequest) String 

func (x *SyncRequest) String() string

type SyncServer 

type SyncServer interface {
	Sync(context.Context, *SyncRequest) (*SyncReply, error)
}

SyncServer is the server API for Sync service.

type UnimplementedMaintainerServer 

type UnimplementedMaintainerServer struct {
}

UnimplementedMaintainerServer can be embedded to have forward compatible implementations.

func (*UnimplementedMaintainerServer) ChangeStatus 

func (*UnimplementedMaintainerServer) ChangeStatus(context.Context, *StatusRequest) (*StatusReply, error)

func (*UnimplementedMaintainerServer) Invalid 

func (*UnimplementedMaintainerServer) Invalid(Maintainer_InvalidServer) error

func (*UnimplementedMaintainerServer) Query 

func (*UnimplementedMaintainerServer) Query(context.Context, *QueryRequest) (*QueryReply, error)

func (*UnimplementedMaintainerServer) Register 

func (*UnimplementedMaintainerServer) Register(context.Context, *RegisterRequest) (*RegisterReply, error)

type UnimplementedSyncServer 

type UnimplementedSyncServer struct {
}

UnimplementedSyncServer can be embedded to have forward compatible implementations.

func (*UnimplementedSyncServer) Sync 

func (*UnimplementedSyncServer) Sync(context.Context, *SyncRequest) (*SyncReply, 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.