services

Documentation

Index

• Variables
• func RegisterRedisDeploymentStrategyServer(s *grpc.Server, srv RedisDeploymentStrategyServer)
• type Error
  • func (*Error) Descriptor() ([]byte, []int)
  • func (x *Error) GetMessage() string
  • func (*Error) ProtoMessage()
  • func (x *Error) ProtoReflect() protoreflect.Message
  • func (x *Error) Reset()
  • func (x *Error) String() string
• type RedisClientConfig
  • func (*RedisClientConfig) Descriptor() ([]byte, []int)
  • func (x *RedisClientConfig) GetAddrs() []string
  • func (x *RedisClientConfig) GetDB() int32
  • func (x *RedisClientConfig) GetPassword() string
  • func (x *RedisClientConfig) GetRouteByLatency() bool
  • func (x *RedisClientConfig) GetRouteRandomly() bool
  • func (x *RedisClientConfig) GetUser() string
  • func (*RedisClientConfig) ProtoMessage()
  • func (x *RedisClientConfig) ProtoReflect() protoreflect.Message
  • func (x *RedisClientConfig) Reset()
  • func (x *RedisClientConfig) String() string
• type RedisDeploymentConfig
  • func (*RedisDeploymentConfig) Descriptor() ([]byte, []int)
  • func (x *RedisDeploymentConfig) GetEnv() map[string]string
  • func (x *RedisDeploymentConfig) GetName() string
  • func (*RedisDeploymentConfig) ProtoMessage()
  • func (x *RedisDeploymentConfig) ProtoReflect() protoreflect.Message
  • func (x *RedisDeploymentConfig) Reset()
  • func (x *RedisDeploymentConfig) String() string
• type RedisDeploymentStrategyClient
  • func NewRedisDeploymentStrategyClient(cc grpc.ClientConnInterface) RedisDeploymentStrategyClient
• type RedisDeploymentStrategyServer
• type UnimplementedRedisDeploymentStrategyServer
  • func (*UnimplementedRedisDeploymentStrategyServer) Deploy(context.Context, *RedisDeploymentConfig) (*RedisClientConfig, error)
  • func (*UnimplementedRedisDeploymentStrategyServer) Undeploy(context.Context, *RedisDeploymentConfig) (*Error, error)

Variables

var File_redis_deploy_proto protoreflect.FileDescriptor

Functions

func RegisterRedisDeploymentStrategyServer

func RegisterRedisDeploymentStrategyServer(s *grpc.Server, srv RedisDeploymentStrategyServer)

Types

type Error

type Error struct {
	Message *string `protobuf:"bytes,1,opt,name=message,proto3,oneof" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetMessage

func (x *Error) GetMessage() string

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) ProtoReflect

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

func (*Error) Reset

func (x *Error) Reset()

func (*Error) String

func (x *Error) String() string

type RedisClientConfig

type RedisClientConfig struct {
	DB             int32    `protobuf:"varint,1,opt,name=DB,proto3" json:"DB,omitempty"`
	User           string   `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Password       string   `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	RouteByLatency bool     `protobuf:"varint,4,opt,name=RouteByLatency,proto3" json:"RouteByLatency,omitempty"`
	RouteRandomly  bool     `protobuf:"varint,5,opt,name=RouteRandomly,proto3" json:"RouteRandomly,omitempty"`
	Addrs          []string `protobuf:"bytes,6,rep,name=Addrs,proto3" json:"Addrs,omitempty"`
	// contains filtered or unexported fields
}

func (*RedisClientConfig) Descriptor

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

Deprecated: Use RedisClientConfig.ProtoReflect.Descriptor instead.

func (*RedisClientConfig) GetAddrs

func (x *RedisClientConfig) GetAddrs() []string

func (*RedisClientConfig) GetDB

func (x *RedisClientConfig) GetDB() int32

func (*RedisClientConfig) GetPassword

func (x *RedisClientConfig) GetPassword() string

func (*RedisClientConfig) GetRouteByLatency

func (x *RedisClientConfig) GetRouteByLatency() bool

func (*RedisClientConfig) GetRouteRandomly

func (x *RedisClientConfig) GetRouteRandomly() bool

func (*RedisClientConfig) GetUser

func (x *RedisClientConfig) GetUser() string

func (*RedisClientConfig) ProtoMessage

func (*RedisClientConfig) ProtoMessage()

func (*RedisClientConfig) ProtoReflect

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

func (*RedisClientConfig) Reset

func (x *RedisClientConfig) Reset()

func (*RedisClientConfig) String

func (x *RedisClientConfig) String() string

type RedisDeploymentConfig

type RedisDeploymentConfig struct {
	Name string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Env  map[string]string `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RedisDeploymentConfig) Descriptor

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

Deprecated: Use RedisDeploymentConfig.ProtoReflect.Descriptor instead.

func (*RedisDeploymentConfig) GetEnv

func (x *RedisDeploymentConfig) GetEnv() map[string]string

func (*RedisDeploymentConfig) GetName

func (x *RedisDeploymentConfig) GetName() string

func (*RedisDeploymentConfig) ProtoMessage

func (*RedisDeploymentConfig) ProtoMessage()

func (*RedisDeploymentConfig) ProtoReflect

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

func (*RedisDeploymentConfig) Reset

func (x *RedisDeploymentConfig) Reset()

func (*RedisDeploymentConfig) String

func (x *RedisDeploymentConfig) String() string

type RedisDeploymentStrategyClient

type RedisDeploymentStrategyClient interface {
	Deploy(ctx context.Context, in *RedisDeploymentConfig, opts ...grpc.CallOption) (*RedisClientConfig, error)
	Undeploy(ctx context.Context, in *RedisDeploymentConfig, opts ...grpc.CallOption) (*Error, error)
}

RedisDeploymentStrategyClient is the client API for RedisDeploymentStrategy service.

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

func NewRedisDeploymentStrategyClient

func NewRedisDeploymentStrategyClient(cc grpc.ClientConnInterface) RedisDeploymentStrategyClient

type RedisDeploymentStrategyServer

type RedisDeploymentStrategyServer interface {
	Deploy(context.Context, *RedisDeploymentConfig) (*RedisClientConfig, error)
	Undeploy(context.Context, *RedisDeploymentConfig) (*Error, error)
}

RedisDeploymentStrategyServer is the server API for RedisDeploymentStrategy service.

type UnimplementedRedisDeploymentStrategyServer

type UnimplementedRedisDeploymentStrategyServer struct {
}

UnimplementedRedisDeploymentStrategyServer can be embedded to have forward compatible implementations.

func (*UnimplementedRedisDeploymentStrategyServer) Deploy

func (*UnimplementedRedisDeploymentStrategyServer) Deploy(context.Context, *RedisDeploymentConfig) (*RedisClientConfig, error)

func (*UnimplementedRedisDeploymentStrategyServer) Undeploy

func (*UnimplementedRedisDeploymentStrategyServer) Undeploy(context.Context, *RedisDeploymentConfig) (*Error, error)