blackhole

package
v0.0.0-...-b8642be Latest Latest
Warning

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

 Go to latest Published: Jul 1, 2020 License: MIT Imports: 7 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CompareKind_name = map[int32]string{
	0: "NO_VALUE_COMPARE",
	1: "ALL",
	2: "ANY",
}
View Source 
var CompareKind_value = map[string]int32{
	"NO_VALUE_COMPARE": 0,
	"ALL":              1,
	"ANY":              2,
}
View Source 
var PayloadKind_name = map[int32]string{
	0: "NO_VALUE_PAYLOAD",
	1: "FILE",
	2: "ENV",
	3: "ACTION",
}
View Source 
var PayloadKind_value = map[string]int32{
	"NO_VALUE_PAYLOAD": 0,
	"FILE":             1,
	"ENV":              2,
	"ACTION":           3,
}
View Source 
var StrategyKind_name = map[int32]string{
	0: "NO_VALUE_STRATEGY",
	1: "AT_ONCE",
	2: "ROLLING_UPDATE",
	3: "CANARY",
}
View Source 
var StrategyKind_value = map[string]int32{
	"NO_VALUE_STRATEGY": 0,
	"AT_ONCE":           1,
	"ROLLING_UPDATE":    2,
	"CANARY":            3,
}
View Source 
var TaskKind_name = map[int32]string{
	0: "NO_VALUE_TASK",
	1: "CONFIGS",
	2: "ACTIONS",
	3: "SECRETS",
	4: "NAMESPACES",
	5: "ROLES",
	6: "TOPOLOGY",
}
View Source 
var TaskKind_value = map[string]int32{
	"NO_VALUE_TASK": 0,
	"CONFIGS":       1,
	"ACTIONS":       2,
	"SECRETS":       3,
	"NAMESPACES":    4,
	"ROLES":         5,
	"TOPOLOGY":      6,
}

Functions

func RegisterBlackHoleServiceServer 

func RegisterBlackHoleServiceServer(s *grpc.Server, srv BlackHoleServiceServer)

Types

type BlackHoleServiceClient 

type BlackHoleServiceClient interface {
	Put(ctx context.Context, in *PutReq, opts ...grpc.CallOption) (*Resp, error)
}

BlackHoleServiceClient is the client API for BlackHoleService service.

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

func NewBlackHoleServiceClient 

func NewBlackHoleServiceClient(cc grpc.ClientConnInterface) BlackHoleServiceClient

type BlackHoleServiceServer 

type BlackHoleServiceServer interface {
	Put(context.Context, *PutReq) (*Resp, error)
}

BlackHoleServiceServer is the server API for BlackHoleService service.

type CompareKind 

type CompareKind int32
const (
	CompareKind_NO_VALUE_COMPARE CompareKind = 0
	CompareKind_ALL              CompareKind = 1
	CompareKind_ANY              CompareKind = 2
)

func (CompareKind) EnumDescriptor 

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

func (CompareKind) String 

func (x CompareKind) String() string

type Metadata 

type Metadata struct {
	TaskName             string   `protobuf:"bytes,1,opt,name=taskName,proto3" json:"taskName,omitempty"`
	Timestamp            int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Namespace            string   `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ForceNamespaceQueue  bool     `protobuf:"varint,4,opt,name=forceNamespaceQueue,proto3" json:"forceNamespaceQueue,omitempty"`
	Queue                string   `protobuf:"bytes,5,opt,name=queue,proto3" json:"queue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Metadata) Descriptor 

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

func (*Metadata) GetForceNamespaceQueue 

func (m *Metadata) GetForceNamespaceQueue() bool

func (*Metadata) GetNamespace 

func (m *Metadata) GetNamespace() string

func (*Metadata) GetQueue 

func (m *Metadata) GetQueue() string

func (*Metadata) GetTaskName 

func (m *Metadata) GetTaskName() string

func (*Metadata) GetTimestamp 

func (m *Metadata) GetTimestamp() int64

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type Payload 

type Payload struct {
	Kind                 PayloadKind       `protobuf:"varint,1,opt,name=kind,proto3,enum=blackhole.PayloadKind" json:"kind,omitempty"`
	Value                map[string]string `` /* 151-byte string literal not displayed */
	Index                []string          `protobuf:"bytes,3,rep,name=index,proto3" json:"index,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Payload) Descriptor 

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

func (*Payload) GetIndex 

func (m *Payload) GetIndex() []string

func (*Payload) GetKind 

func (m *Payload) GetKind() PayloadKind

func (*Payload) GetValue 

func (m *Payload) GetValue() map[string]string

func (*Payload) ProtoMessage 

func (*Payload) ProtoMessage()

func (*Payload) Reset 

func (m *Payload) Reset()

func (*Payload) String 

func (m *Payload) String() string

func (*Payload) XXX_DiscardUnknown 

func (m *Payload) XXX_DiscardUnknown()

func (*Payload) XXX_Marshal 

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

func (*Payload) XXX_Merge 

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

func (*Payload) XXX_Size 

func (m *Payload) XXX_Size() int

func (*Payload) XXX_Unmarshal 

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

type PayloadKind 

type PayloadKind int32
const (
	PayloadKind_NO_VALUE_PAYLOAD PayloadKind = 0
	PayloadKind_FILE             PayloadKind = 1
	PayloadKind_ENV              PayloadKind = 2
	PayloadKind_ACTION           PayloadKind = 3
)

func (PayloadKind) EnumDescriptor 

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

func (PayloadKind) String 

func (x PayloadKind) String() string

type PutReq 

type PutReq struct {
	Version              string            `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	UserId               string            `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	Kind                 TaskKind          `protobuf:"varint,3,opt,name=kind,proto3,enum=blackhole.TaskKind" json:"kind,omitempty"`
	Mtdata               *Metadata         `protobuf:"bytes,4,opt,name=mtdata,proto3" json:"mtdata,omitempty"`
	Tasks                []*PutTask        `protobuf:"bytes,5,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Extras               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Reques messages

func (*PutReq) Descriptor 

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

func (*PutReq) GetExtras 

func (m *PutReq) GetExtras() map[string]string

func (*PutReq) GetKind 

func (m *PutReq) GetKind() TaskKind

func (*PutReq) GetMtdata 

func (m *PutReq) GetMtdata() *Metadata

func (*PutReq) GetTasks 

func (m *PutReq) GetTasks() []*PutTask

func (*PutReq) GetUserId 

func (m *PutReq) GetUserId() string

func (*PutReq) GetVersion 

func (m *PutReq) GetVersion() string

func (*PutReq) ProtoMessage 

func (*PutReq) ProtoMessage()

func (*PutReq) Reset 

func (m *PutReq) Reset()

func (*PutReq) String 

func (m *PutReq) String() string

func (*PutReq) XXX_DiscardUnknown 

func (m *PutReq) XXX_DiscardUnknown()

func (*PutReq) XXX_Marshal 

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

func (*PutReq) XXX_Merge 

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

func (*PutReq) XXX_Size 

func (m *PutReq) XXX_Size() int

func (*PutReq) XXX_Unmarshal 

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

type PutTask 

type PutTask struct {
	RegionId             string     `protobuf:"bytes,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty"`
	ClusterId            string     `protobuf:"bytes,2,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	Strategy             *Strategy  `protobuf:"bytes,3,opt,name=strategy,proto3" json:"strategy,omitempty"`
	Selector             *Selector  `protobuf:"bytes,4,opt,name=selector,proto3" json:"selector,omitempty"`
	Payload              []*Payload `protobuf:"bytes,5,rep,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PutTask) Descriptor 

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

func (*PutTask) GetClusterId 

func (m *PutTask) GetClusterId() string

func (*PutTask) GetPayload 

func (m *PutTask) GetPayload() []*Payload

func (*PutTask) GetRegionId 

func (m *PutTask) GetRegionId() string

func (*PutTask) GetSelector 

func (m *PutTask) GetSelector() *Selector

func (*PutTask) GetStrategy 

func (m *PutTask) GetStrategy() *Strategy

func (*PutTask) ProtoMessage 

func (*PutTask) ProtoMessage()

func (*PutTask) Reset 

func (m *PutTask) Reset()

func (*PutTask) String 

func (m *PutTask) String() string

func (*PutTask) XXX_DiscardUnknown 

func (m *PutTask) XXX_DiscardUnknown()

func (*PutTask) XXX_Marshal 

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

func (*PutTask) XXX_Merge 

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

func (*PutTask) XXX_Size 

func (m *PutTask) XXX_Size() int

func (*PutTask) XXX_Unmarshal 

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

type Resp 

type Resp struct {
	Msg                  string   `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Response message

func (*Resp) Descriptor 

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

func (*Resp) GetMsg 

func (m *Resp) GetMsg() string

func (*Resp) ProtoMessage 

func (*Resp) ProtoMessage()

func (*Resp) Reset 

func (m *Resp) Reset()

func (*Resp) String 

func (m *Resp) String() string

func (*Resp) XXX_DiscardUnknown 

func (m *Resp) XXX_DiscardUnknown()

func (*Resp) XXX_Marshal 

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

func (*Resp) XXX_Merge 

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

func (*Resp) XXX_Size 

func (m *Resp) XXX_Size() int

func (*Resp) XXX_Unmarshal 

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

type Selector 

type Selector struct {
	Kind                 CompareKind       `protobuf:"varint,1,opt,name=kind,proto3,enum=blackhole.CompareKind" json:"kind,omitempty"`
	Labels               map[string]string `` /* 153-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Selector) Descriptor 

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

func (*Selector) GetKind 

func (m *Selector) GetKind() CompareKind

func (*Selector) GetLabels 

func (m *Selector) GetLabels() map[string]string

func (*Selector) ProtoMessage 

func (*Selector) ProtoMessage()

func (*Selector) Reset 

func (m *Selector) Reset()

func (*Selector) String 

func (m *Selector) String() string

func (*Selector) XXX_DiscardUnknown 

func (m *Selector) XXX_DiscardUnknown()

func (*Selector) XXX_Marshal 

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

func (*Selector) XXX_Merge 

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

func (*Selector) XXX_Size 

func (m *Selector) XXX_Size() int

func (*Selector) XXX_Unmarshal 

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

type Strategy 

type Strategy struct {
	Type                 StrategyKind      `protobuf:"varint,1,opt,name=type,proto3,enum=blackhole.StrategyKind" json:"type,omitempty"`
	Kind                 string            `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
	Interval             string            `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty"`
	Retry                map[string]string `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Request helper messages

func (*Strategy) Descriptor 

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

func (*Strategy) GetInterval 

func (m *Strategy) GetInterval() string

func (*Strategy) GetKind 

func (m *Strategy) GetKind() string

func (*Strategy) GetRetry 

func (m *Strategy) GetRetry() map[string]string

func (*Strategy) GetType 

func (m *Strategy) GetType() StrategyKind

func (*Strategy) ProtoMessage 

func (*Strategy) ProtoMessage()

func (*Strategy) Reset 

func (m *Strategy) Reset()

func (*Strategy) String 

func (m *Strategy) String() string

func (*Strategy) XXX_DiscardUnknown 

func (m *Strategy) XXX_DiscardUnknown()

func (*Strategy) XXX_Marshal 

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

func (*Strategy) XXX_Merge 

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

func (*Strategy) XXX_Size 

func (m *Strategy) XXX_Size() int

func (*Strategy) XXX_Unmarshal 

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

type StrategyKind 

type StrategyKind int32
const (
	StrategyKind_NO_VALUE_STRATEGY StrategyKind = 0
	StrategyKind_AT_ONCE           StrategyKind = 1
	StrategyKind_ROLLING_UPDATE    StrategyKind = 2
	StrategyKind_CANARY            StrategyKind = 3
)

func (StrategyKind) EnumDescriptor 

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

func (StrategyKind) String 

func (x StrategyKind) String() string

type TaskKind 

type TaskKind int32

Enums 

const (
	TaskKind_NO_VALUE_TASK TaskKind = 0
	TaskKind_CONFIGS       TaskKind = 1
	TaskKind_ACTIONS       TaskKind = 2
	TaskKind_SECRETS       TaskKind = 3
	TaskKind_NAMESPACES    TaskKind = 4
	TaskKind_ROLES         TaskKind = 5
	TaskKind_TOPOLOGY      TaskKind = 6
)

func (TaskKind) EnumDescriptor 

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

func (TaskKind) String 

func (x TaskKind) String() string

type UnimplementedBlackHoleServiceServer 

type UnimplementedBlackHoleServiceServer struct {
}

UnimplementedBlackHoleServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedBlackHoleServiceServer) Put 

func (*UnimplementedBlackHoleServiceServer) Put(ctx context.Context, req *PutReq) (*Resp, 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.