alertmanagerpb

package
v0.0.0-...-2ecc15d Latest Latest
Warning

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

 Go to latest Published: Dec 19, 2024 License: AGPL-3.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthAlertmanager = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAlertmanager   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ReadStateStatus_name = map[int32]string{
	0: "READ_UNSPECIFIED",
	1: "READ_OK",
	2: "READ_ERROR",
	3: "READ_USER_NOT_FOUND",
}
View Source 
var ReadStateStatus_value = map[string]int32{
	"READ_UNSPECIFIED":    0,
	"READ_OK":             1,
	"READ_ERROR":          2,
	"READ_USER_NOT_FOUND": 3,
}
View Source 
var UpdateStateStatus_name = map[int32]string{
	0: "OK",
	2: "MERGE_ERROR",
	3: "USER_NOT_FOUND",
}
View Source 
var UpdateStateStatus_value = map[string]int32{
	"OK":             0,
	"MERGE_ERROR":    2,
	"USER_NOT_FOUND": 3,
}

Functions

func RegisterAlertmanagerServer 

func RegisterAlertmanagerServer(s *grpc.Server, srv AlertmanagerServer)

Types

type AlertmanagerClient 

type AlertmanagerClient interface {
	HandleRequest(ctx context.Context, in *httpgrpc.HTTPRequest, opts ...grpc.CallOption) (*httpgrpc.HTTPResponse, error)
	UpdateState(ctx context.Context, in *clusterpb.Part, opts ...grpc.CallOption) (*UpdateStateResponse, error)
	ReadState(ctx context.Context, in *ReadStateRequest, opts ...grpc.CallOption) (*ReadStateResponse, error)
}

AlertmanagerClient is the client API for Alertmanager service.

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

func NewAlertmanagerClient 

func NewAlertmanagerClient(cc *grpc.ClientConn) AlertmanagerClient

type AlertmanagerServer 

type AlertmanagerServer interface {
	HandleRequest(context.Context, *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)
	UpdateState(context.Context, *clusterpb.Part) (*UpdateStateResponse, error)
	ReadState(context.Context, *ReadStateRequest) (*ReadStateResponse, error)
}

AlertmanagerServer is the server API for Alertmanager service.

type ReadStateRequest 

type ReadStateRequest struct {
}

func (*ReadStateRequest) Descriptor 

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

func (*ReadStateRequest) Equal 

func (this *ReadStateRequest) Equal(that interface{}) bool

func (*ReadStateRequest) GoString 

func (this *ReadStateRequest) GoString() string

func (*ReadStateRequest) Marshal 

func (m *ReadStateRequest) Marshal() (dAtA []byte, err error)

func (*ReadStateRequest) MarshalTo 

func (m *ReadStateRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadStateRequest) MarshalToSizedBuffer 

func (m *ReadStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadStateRequest) ProtoMessage 

func (*ReadStateRequest) ProtoMessage()

func (*ReadStateRequest) Reset 

func (m *ReadStateRequest) Reset()

func (*ReadStateRequest) Size 

func (m *ReadStateRequest) Size() (n int)

func (*ReadStateRequest) String 

func (this *ReadStateRequest) String() string

func (*ReadStateRequest) Unmarshal 

func (m *ReadStateRequest) Unmarshal(dAtA []byte) error

func (*ReadStateRequest) XXX_DiscardUnknown 

func (m *ReadStateRequest) XXX_DiscardUnknown()

func (*ReadStateRequest) XXX_Marshal 

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

func (*ReadStateRequest) XXX_Merge 

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

func (*ReadStateRequest) XXX_Size 

func (m *ReadStateRequest) XXX_Size() int

func (*ReadStateRequest) XXX_Unmarshal 

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

type ReadStateResponse 

type ReadStateResponse struct {
	Status ReadStateStatus      `protobuf:"varint,1,opt,name=status,proto3,enum=alertmanagerpb.ReadStateStatus" json:"status,omitempty"`
	Error  string               `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	State  *clusterpb.FullState `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
}

func (*ReadStateResponse) Descriptor 

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

func (*ReadStateResponse) GetError 

func (m *ReadStateResponse) GetError() string

func (*ReadStateResponse) GetState 

func (m *ReadStateResponse) GetState() *clusterpb.FullState

func (*ReadStateResponse) GetStatus 

func (m *ReadStateResponse) GetStatus() ReadStateStatus

func (*ReadStateResponse) GoString 

func (this *ReadStateResponse) GoString() string

func (*ReadStateResponse) Marshal 

func (m *ReadStateResponse) Marshal() (dAtA []byte, err error)

func (*ReadStateResponse) MarshalTo 

func (m *ReadStateResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReadStateResponse) MarshalToSizedBuffer 

func (m *ReadStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadStateResponse) ProtoMessage 

func (*ReadStateResponse) ProtoMessage()

func (*ReadStateResponse) Reset 

func (m *ReadStateResponse) Reset()

func (*ReadStateResponse) Size 

func (m *ReadStateResponse) Size() (n int)

func (*ReadStateResponse) String 

func (this *ReadStateResponse) String() string

func (*ReadStateResponse) Unmarshal 

func (m *ReadStateResponse) Unmarshal(dAtA []byte) error

func (*ReadStateResponse) XXX_DiscardUnknown 

func (m *ReadStateResponse) XXX_DiscardUnknown()

func (*ReadStateResponse) XXX_Marshal 

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

func (*ReadStateResponse) XXX_Merge 

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

func (*ReadStateResponse) XXX_Size 

func (m *ReadStateResponse) XXX_Size() int

func (*ReadStateResponse) XXX_Unmarshal 

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

type ReadStateStatus 

type ReadStateStatus int32
const (
	READ_UNSPECIFIED    ReadStateStatus = 0
	READ_OK             ReadStateStatus = 1
	READ_ERROR          ReadStateStatus = 2
	READ_USER_NOT_FOUND ReadStateStatus = 3
)

func (ReadStateStatus) EnumDescriptor 

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

func (ReadStateStatus) String 

func (x ReadStateStatus) String() string

type UnimplementedAlertmanagerServer 

type UnimplementedAlertmanagerServer struct {
}

UnimplementedAlertmanagerServer can be embedded to have forward compatible implementations.

func (*UnimplementedAlertmanagerServer) HandleRequest 

func (*UnimplementedAlertmanagerServer) HandleRequest(ctx context.Context, req *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)

func (*UnimplementedAlertmanagerServer) ReadState 

func (*UnimplementedAlertmanagerServer) ReadState(ctx context.Context, req *ReadStateRequest) (*ReadStateResponse, error)

func (*UnimplementedAlertmanagerServer) UpdateState 

func (*UnimplementedAlertmanagerServer) UpdateState(ctx context.Context, req *clusterpb.Part) (*UpdateStateResponse, error)

type UpdateStateResponse 

type UpdateStateResponse struct {
	Status UpdateStateStatus `protobuf:"varint,1,opt,name=status,proto3,enum=alertmanagerpb.UpdateStateStatus" json:"status,omitempty"`
	Error  string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*UpdateStateResponse) Descriptor 

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

func (*UpdateStateResponse) Equal 

func (this *UpdateStateResponse) Equal(that interface{}) bool

func (*UpdateStateResponse) GetError 

func (m *UpdateStateResponse) GetError() string

func (*UpdateStateResponse) GetStatus 

func (m *UpdateStateResponse) GetStatus() UpdateStateStatus

func (*UpdateStateResponse) GoString 

func (this *UpdateStateResponse) GoString() string

func (*UpdateStateResponse) Marshal 

func (m *UpdateStateResponse) Marshal() (dAtA []byte, err error)

func (*UpdateStateResponse) MarshalTo 

func (m *UpdateStateResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateStateResponse) MarshalToSizedBuffer 

func (m *UpdateStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateStateResponse) ProtoMessage 

func (*UpdateStateResponse) ProtoMessage()

func (*UpdateStateResponse) Reset 

func (m *UpdateStateResponse) Reset()

func (*UpdateStateResponse) Size 

func (m *UpdateStateResponse) Size() (n int)

func (*UpdateStateResponse) String 

func (this *UpdateStateResponse) String() string

func (*UpdateStateResponse) Unmarshal 

func (m *UpdateStateResponse) Unmarshal(dAtA []byte) error

func (*UpdateStateResponse) XXX_DiscardUnknown 

func (m *UpdateStateResponse) XXX_DiscardUnknown()

func (*UpdateStateResponse) XXX_Marshal 

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

func (*UpdateStateResponse) XXX_Merge 

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

func (*UpdateStateResponse) XXX_Size 

func (m *UpdateStateResponse) XXX_Size() int

func (*UpdateStateResponse) XXX_Unmarshal 

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

type UpdateStateStatus 

type UpdateStateStatus int32
const (
	OK             UpdateStateStatus = 0
	MERGE_ERROR    UpdateStateStatus = 2
	USER_NOT_FOUND UpdateStateStatus = 3
)

func (UpdateStateStatus) EnumDescriptor 

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

func (UpdateStateStatus) String 

func (x UpdateStateStatus) String() string

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.