Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

instance

package

Go to main page

Versions in this module

v1

v1.0.2

Nov 21, 2022

v1.0.1

Nov 20, 2022

v1.0.0

Nov 20, 2022

v0

v0.0.9

Nov 20, 2022

Changes in this version

+ var File_apps_instance_pb_instance_impl_proto protoreflect.FileDescriptor

v0.0.8

Nov 20, 2022

v0.0.7

Nov 20, 2022

v0.0.6

Nov 20, 2022

v0.0.5

Nov 20, 2022

v0.0.4

Nov 20, 2022

Changes in this version

+ const AppName

+ const DefaultEnvironment

+ const DefaultGroup

+ const DefaultRegion

+ var CommandType_name = map[int32]string

+ var CommandType_value = map[string]int32

+ var File_apps_instance_pb_instance_proto protoreflect.FileDescriptor

+ var Protocal_name = map[int32]string

+ var Protocal_value = map[string]int32

+ var Provider_name = map[int32]string

+ var Provider_value = map[string]int32

+ var Service_ServiceDesc = grpc.ServiceDesc

+ func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

+ type Build struct

+ BuildAt int64

+ GitBranch string

+ GitCommit string

+ Version string

+ func (*Build) Descriptor() ([]byte, []int)

+ func (*Build) ProtoMessage()

+ func (x *Build) GetBuildAt() int64

+ func (x *Build) GetGitBranch() string

+ func (x *Build) GetGitCommit() string

+ func (x *Build) GetVersion() string

+ func (x *Build) ProtoReflect() protoreflect.Message

+ func (x *Build) Reset()

+ func (x *Build) String() string

+ type CommandType int32

+ const CommandType_UPDATE_INSTANCE

+ func (CommandType) Descriptor() protoreflect.EnumDescriptor

+ func (CommandType) EnumDescriptor() ([]byte, []int)

+ func (CommandType) Type() protoreflect.EnumType

+ func (x CommandType) Enum() *CommandType

+ func (x CommandType) Number() protoreflect.EnumNumber

+ func (x CommandType) String() string

+ type Config struct

+ Heartbeat *HeartbeatConfig

+ func NewDefaultConfig() *Config

+ func (*Config) Descriptor() ([]byte, []int)

+ func (*Config) ProtoMessage()

+ func (x *Config) GetHeartbeat() *HeartbeatConfig

+ func (x *Config) ProtoReflect() protoreflect.Message

+ func (x *Config) Reset()

+ func (x *Config) String() string

+ type DescribeInstanceRequest struct

+ Id string

+ func NewDescribeInstanceRequest(id string) *DescribeInstanceRequest

+ func (*DescribeInstanceRequest) Descriptor() ([]byte, []int)

+ func (*DescribeInstanceRequest) ProtoMessage()

+ func (x *DescribeInstanceRequest) GetId() string

+ func (x *DescribeInstanceRequest) ProtoReflect() protoreflect.Message

+ func (x *DescribeInstanceRequest) Reset()

+ func (x *DescribeInstanceRequest) String() string

+ type HeartbeatConfig struct

+ Interval int32

+ Timeout int32

+ func (*HeartbeatConfig) Descriptor() ([]byte, []int)

+ func (*HeartbeatConfig) ProtoMessage()

+ func (x *HeartbeatConfig) GetInterval() int32

+ func (x *HeartbeatConfig) GetTimeout() int32

+ func (x *HeartbeatConfig) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatConfig) Reset()

+ func (x *HeartbeatConfig) String() string

+ type HeartbeatRequest struct

+ InstanceId string

+ func NewHeartbeatRequest(id string) *HeartbeatRequest

+ func (*HeartbeatRequest) Descriptor() ([]byte, []int)

+ func (*HeartbeatRequest) ProtoMessage()

+ func (x *HeartbeatRequest) GetInstanceId() string

+ func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatRequest) Reset()

+ func (x *HeartbeatRequest) String() string

+ type HeartbeatResponse struct

+ Next int32

+ RemoteCommand *RemoteCommand

+ func NewHeartbeatResponse() *HeartbeatResponse

+ func (*HeartbeatResponse) Descriptor() ([]byte, []int)

+ func (*HeartbeatResponse) ProtoMessage()

+ func (x *HeartbeatResponse) GetNext() int32

+ func (x *HeartbeatResponse) GetRemoteCommand() *RemoteCommand

+ func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message

+ func (x *HeartbeatResponse) Reset()

+ func (x *HeartbeatResponse) String() string

+ type Instance struct

+ Config *Config

+ Domain string

+ Id string

+ Namespace string

+ RegistryInfo *RegistryRequest

+ ServiceName string

+ Status *Status

+ func NewDefaultInstance() *Instance

+ func NewInstance(req *RegistryRequest, app *service.Service) (*Instance, error)

+ func (*Instance) Descriptor() ([]byte, []int)

+ func (*Instance) ProtoMessage()

+ func (i *Instance) FullName() string

+ func (x *Instance) GetConfig() *Config

+ func (x *Instance) GetDomain() string

+ func (x *Instance) GetId() string

+ func (x *Instance) GetNamespace() string

+ func (x *Instance) GetRegistryInfo() *RegistryRequest

+ func (x *Instance) GetServiceName() string

+ func (x *Instance) GetStatus() *Status

+ func (x *Instance) ProtoReflect() protoreflect.Message

+ func (x *Instance) Reset()

+ func (x *Instance) String() string

+ type InstanceSet struct

+ Items []*Instance

+ Total int64

+ func NewInstanceSet() *InstanceSet

+ func (*InstanceSet) Descriptor() ([]byte, []int)

+ func (*InstanceSet) ProtoMessage()

+ func (s *InstanceSet) Add(ins *Instance)

+ func (s *InstanceSet) GetGroupInstance(group string) (items []*Instance)

+ func (s *InstanceSet) GetOldGroup() (items []*Instance)

+ func (s *InstanceSet) Len() int

+ func (s *InstanceSet) Less(i, j int) bool

+ func (s *InstanceSet) Swap(i, j int)

+ func (x *InstanceSet) GetItems() []*Instance

+ func (x *InstanceSet) GetTotal() int64

+ func (x *InstanceSet) ProtoReflect() protoreflect.Message

+ func (x *InstanceSet) Reset()

+ func (x *InstanceSet) String() string

+ type Protocal int32

+ const Protocal_GRPC

+ const Protocal_HTTP

+ func (Protocal) Descriptor() protoreflect.EnumDescriptor

+ func (Protocal) EnumDescriptor() ([]byte, []int)

+ func (Protocal) Type() protoreflect.EnumType

+ func (x Protocal) Enum() *Protocal

+ func (x Protocal) Number() protoreflect.EnumNumber

+ func (x Protocal) String() string

+ type Provider int32

+ const Provider_KUBERNETES

+ const Provider_SDK

+ func (Provider) Descriptor() protoreflect.EnumDescriptor

+ func (Provider) EnumDescriptor() ([]byte, []int)

+ func (Provider) Type() protoreflect.EnumType

+ func (x Provider) Enum() *Provider

+ func (x Provider) Number() protoreflect.EnumNumber

+ func (x Provider) String() string

+ type RegistryRequest struct

+ Address string

+ Build *Build

+ Environment string

+ Export bool

+ Group string

+ Name string

+ Protocal Protocal

+ Provider Provider

+ Region string

+ Tags map[string]string

+ func NewRegistryInstance() *RegistryRequest

+ func NewRegistryRequest() *RegistryRequest

+ func (*RegistryRequest) Descriptor() ([]byte, []int)

+ func (*RegistryRequest) ProtoMessage()

+ func (r *RegistryRequest) InstanceFullName() string

+ func (r *RegistryRequest) Validate() error

+ func (x *RegistryRequest) GetAddress() string

+ func (x *RegistryRequest) GetBuild() *Build

+ func (x *RegistryRequest) GetEnvironment() string

+ func (x *RegistryRequest) GetExport() bool

+ func (x *RegistryRequest) GetGroup() string

+ func (x *RegistryRequest) GetName() string

+ func (x *RegistryRequest) GetProtocal() Protocal

+ func (x *RegistryRequest) GetProvider() Provider

+ func (x *RegistryRequest) GetRegion() string

+ func (x *RegistryRequest) GetTags() map[string]string

+ func (x *RegistryRequest) ProtoReflect() protoreflect.Message

+ func (x *RegistryRequest) Reset()

+ func (x *RegistryRequest) String() string

+ type RemoteCommand struct

+ Params map[string]string

+ Type CommandType

+ func (*RemoteCommand) Descriptor() ([]byte, []int)

+ func (*RemoteCommand) ProtoMessage()

+ func (x *RemoteCommand) GetParams() map[string]string

+ func (x *RemoteCommand) GetType() CommandType

+ func (x *RemoteCommand) ProtoReflect() protoreflect.Message

+ func (x *RemoteCommand) Reset()

+ func (x *RemoteCommand) String() string

+ type SearchRequest struct

+ Domain string

+ Environment string

+ Group string

+ Namespace string

+ Page *request.PageRequest

+ Region string

+ ServiceName string

+ Tags map[string]string

+ func NewSearchRequest() *SearchRequest

+ func (*SearchRequest) Descriptor() ([]byte, []int)

+ func (*SearchRequest) ProtoMessage()

+ func (x *SearchRequest) GetDomain() string

+ func (x *SearchRequest) GetEnvironment() string

+ func (x *SearchRequest) GetGroup() string

+ func (x *SearchRequest) GetNamespace() string

+ func (x *SearchRequest) GetPage() *request.PageRequest

+ func (x *SearchRequest) GetRegion() string

+ func (x *SearchRequest) GetServiceName() string

+ func (x *SearchRequest) GetTags() map[string]string

+ func (x *SearchRequest) ProtoReflect() protoreflect.Message

+ func (x *SearchRequest) Reset()

+ func (x *SearchRequest) String() string

+ type ServiceClient interface

+ DescribeInstance func(ctx context.Context, in *DescribeInstanceRequest, opts ...grpc.CallOption) (*Instance, error)

+ Heartbeat func(ctx context.Context, opts ...grpc.CallOption) (Service_HeartbeatClient, error)

+ RegistryInstance func(ctx context.Context, in *RegistryRequest, opts ...grpc.CallOption) (*Instance, error)

+ Search func(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*InstanceSet, error)

+ UnRegistry func(ctx context.Context, in *UnregistryRequest, opts ...grpc.CallOption) (*Instance, error)

+ func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

+ type ServiceServer interface

+ DescribeInstance func(context.Context, *DescribeInstanceRequest) (*Instance, error)

+ Heartbeat func(Service_HeartbeatServer) error

+ RegistryInstance func(context.Context, *RegistryRequest) (*Instance, error)

+ Search func(context.Context, *SearchRequest) (*InstanceSet, error)

+ UnRegistry func(context.Context, *UnregistryRequest) (*Instance, error)

+ type Service_HeartbeatClient interface

+ Recv func() (*HeartbeatResponse, error)

+ Send func(*HeartbeatRequest) error

+ type Service_HeartbeatServer interface

+ Recv func() (*HeartbeatRequest, error)

+ Send func(*HeartbeatResponse) error

+ type Status struct

+ Healthy bool

+ Online int64

+ func NewDefaultStatus() *Status

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

+ func (*Status) ProtoMessage()

+ func (x *Status) GetHealthy() bool

+ func (x *Status) GetOnline() int64

+ func (x *Status) ProtoReflect() protoreflect.Message

+ func (x *Status) Reset()

+ func (x *Status) String() string

+ type UnimplementedServiceServer struct

+ func (UnimplementedServiceServer) DescribeInstance(context.Context, *DescribeInstanceRequest) (*Instance, error)

+ func (UnimplementedServiceServer) Heartbeat(Service_HeartbeatServer) error

+ func (UnimplementedServiceServer) RegistryInstance(context.Context, *RegistryRequest) (*Instance, error)

+ func (UnimplementedServiceServer) Search(context.Context, *SearchRequest) (*InstanceSet, error)

+ func (UnimplementedServiceServer) UnRegistry(context.Context, *UnregistryRequest) (*Instance, error)

+ type UnregistryRequest struct

+ InstanceId string

+ func NewUnregistryRequest(instanceId string) *UnregistryRequest

+ func (*UnregistryRequest) Descriptor() ([]byte, []int)

+ func (*UnregistryRequest) ProtoMessage()

+ func (x *UnregistryRequest) GetInstanceId() string

+ func (x *UnregistryRequest) ProtoReflect() protoreflect.Message

+ func (x *UnregistryRequest) Reset()

+ func (x *UnregistryRequest) String() string

+ type UnsafeServiceServer interface

v0.0.3

Nov 20, 2022

v0.0.1

Nov 20, 2022