Documentation ¶
Index ¶
- Variables
- func RegisterAlertmanagerServer(s *grpc.Server, srv AlertmanagerServer)
- type AlertmanagerClient
- type AlertmanagerServer
- type ReadStateRequest
- func (*ReadStateRequest) Descriptor() ([]byte, []int)
- func (this *ReadStateRequest) Equal(that interface{}) bool
- func (this *ReadStateRequest) GoString() string
- func (m *ReadStateRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadStateRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadStateRequest) ProtoMessage()
- func (m *ReadStateRequest) Reset()
- func (m *ReadStateRequest) Size() (n int)
- func (this *ReadStateRequest) String() string
- func (m *ReadStateRequest) Unmarshal(dAtA []byte) error
- func (m *ReadStateRequest) XXX_DiscardUnknown()
- func (m *ReadStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadStateRequest) XXX_Merge(src proto.Message)
- func (m *ReadStateRequest) XXX_Size() int
- func (m *ReadStateRequest) XXX_Unmarshal(b []byte) error
- type ReadStateResponse
- func (*ReadStateResponse) Descriptor() ([]byte, []int)
- func (m *ReadStateResponse) GetError() string
- func (m *ReadStateResponse) GetState() *clusterpb.FullState
- func (m *ReadStateResponse) GetStatus() ReadStateStatus
- func (this *ReadStateResponse) GoString() string
- func (m *ReadStateResponse) Marshal() (dAtA []byte, err error)
- func (m *ReadStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadStateResponse) ProtoMessage()
- func (m *ReadStateResponse) Reset()
- func (m *ReadStateResponse) Size() (n int)
- func (this *ReadStateResponse) String() string
- func (m *ReadStateResponse) Unmarshal(dAtA []byte) error
- func (m *ReadStateResponse) XXX_DiscardUnknown()
- func (m *ReadStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadStateResponse) XXX_Merge(src proto.Message)
- func (m *ReadStateResponse) XXX_Size() int
- func (m *ReadStateResponse) XXX_Unmarshal(b []byte) error
- type ReadStateStatus
- type UnimplementedAlertmanagerServer
- func (*UnimplementedAlertmanagerServer) HandleRequest(ctx context.Context, req *httpgrpc.HTTPRequest) (*httpgrpc.HTTPResponse, error)
- func (*UnimplementedAlertmanagerServer) ReadState(ctx context.Context, req *ReadStateRequest) (*ReadStateResponse, error)
- func (*UnimplementedAlertmanagerServer) UpdateState(ctx context.Context, req *clusterpb.Part) (*UpdateStateResponse, error)
- type UpdateStateResponse
- func (*UpdateStateResponse) Descriptor() ([]byte, []int)
- func (this *UpdateStateResponse) Equal(that interface{}) bool
- func (m *UpdateStateResponse) GetError() string
- func (m *UpdateStateResponse) GetStatus() UpdateStateStatus
- func (this *UpdateStateResponse) GoString() string
- func (m *UpdateStateResponse) Marshal() (dAtA []byte, err error)
- func (m *UpdateStateResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *UpdateStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*UpdateStateResponse) ProtoMessage()
- func (m *UpdateStateResponse) Reset()
- func (m *UpdateStateResponse) Size() (n int)
- func (this *UpdateStateResponse) String() string
- func (m *UpdateStateResponse) Unmarshal(dAtA []byte) error
- func (m *UpdateStateResponse) XXX_DiscardUnknown()
- func (m *UpdateStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpdateStateResponse) XXX_Merge(src proto.Message)
- func (m *UpdateStateResponse) XXX_Size() int
- func (m *UpdateStateResponse) XXX_Unmarshal(b []byte) error
- type UpdateStateStatus
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 ¶ added in v1.9.0
type ReadStateRequest struct { }
func (*ReadStateRequest) Descriptor ¶ added in v1.9.0
func (*ReadStateRequest) Descriptor() ([]byte, []int)
func (*ReadStateRequest) Equal ¶ added in v1.9.0
func (this *ReadStateRequest) Equal(that interface{}) bool
func (*ReadStateRequest) GoString ¶ added in v1.9.0
func (this *ReadStateRequest) GoString() string
func (*ReadStateRequest) Marshal ¶ added in v1.9.0
func (m *ReadStateRequest) Marshal() (dAtA []byte, err error)
func (*ReadStateRequest) MarshalTo ¶ added in v1.9.0
func (m *ReadStateRequest) MarshalTo(dAtA []byte) (int, error)
func (*ReadStateRequest) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *ReadStateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadStateRequest) ProtoMessage ¶ added in v1.9.0
func (*ReadStateRequest) ProtoMessage()
func (*ReadStateRequest) Reset ¶ added in v1.9.0
func (m *ReadStateRequest) Reset()
func (*ReadStateRequest) Size ¶ added in v1.9.0
func (m *ReadStateRequest) Size() (n int)
func (*ReadStateRequest) String ¶ added in v1.9.0
func (this *ReadStateRequest) String() string
func (*ReadStateRequest) Unmarshal ¶ added in v1.9.0
func (m *ReadStateRequest) Unmarshal(dAtA []byte) error
func (*ReadStateRequest) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *ReadStateRequest) XXX_DiscardUnknown()
func (*ReadStateRequest) XXX_Marshal ¶ added in v1.9.0
func (m *ReadStateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadStateRequest) XXX_Merge ¶ added in v1.9.0
func (m *ReadStateRequest) XXX_Merge(src proto.Message)
func (*ReadStateRequest) XXX_Size ¶ added in v1.9.0
func (m *ReadStateRequest) XXX_Size() int
func (*ReadStateRequest) XXX_Unmarshal ¶ added in v1.9.0
func (m *ReadStateRequest) XXX_Unmarshal(b []byte) error
type ReadStateResponse ¶ added in v1.9.0
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 ¶ added in v1.9.0
func (*ReadStateResponse) Descriptor() ([]byte, []int)
func (*ReadStateResponse) GetError ¶ added in v1.9.0
func (m *ReadStateResponse) GetError() string
func (*ReadStateResponse) GetState ¶ added in v1.9.0
func (m *ReadStateResponse) GetState() *clusterpb.FullState
func (*ReadStateResponse) GetStatus ¶ added in v1.9.0
func (m *ReadStateResponse) GetStatus() ReadStateStatus
func (*ReadStateResponse) GoString ¶ added in v1.9.0
func (this *ReadStateResponse) GoString() string
func (*ReadStateResponse) Marshal ¶ added in v1.9.0
func (m *ReadStateResponse) Marshal() (dAtA []byte, err error)
func (*ReadStateResponse) MarshalTo ¶ added in v1.9.0
func (m *ReadStateResponse) MarshalTo(dAtA []byte) (int, error)
func (*ReadStateResponse) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *ReadStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadStateResponse) ProtoMessage ¶ added in v1.9.0
func (*ReadStateResponse) ProtoMessage()
func (*ReadStateResponse) Reset ¶ added in v1.9.0
func (m *ReadStateResponse) Reset()
func (*ReadStateResponse) Size ¶ added in v1.9.0
func (m *ReadStateResponse) Size() (n int)
func (*ReadStateResponse) String ¶ added in v1.9.0
func (this *ReadStateResponse) String() string
func (*ReadStateResponse) Unmarshal ¶ added in v1.9.0
func (m *ReadStateResponse) Unmarshal(dAtA []byte) error
func (*ReadStateResponse) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *ReadStateResponse) XXX_DiscardUnknown()
func (*ReadStateResponse) XXX_Marshal ¶ added in v1.9.0
func (m *ReadStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadStateResponse) XXX_Merge ¶ added in v1.9.0
func (m *ReadStateResponse) XXX_Merge(src proto.Message)
func (*ReadStateResponse) XXX_Size ¶ added in v1.9.0
func (m *ReadStateResponse) XXX_Size() int
func (*ReadStateResponse) XXX_Unmarshal ¶ added in v1.9.0
func (m *ReadStateResponse) XXX_Unmarshal(b []byte) error
type ReadStateStatus ¶ added in v1.9.0
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 ¶ added in v1.9.0
func (ReadStateStatus) EnumDescriptor() ([]byte, []int)
func (ReadStateStatus) String ¶ added in v1.9.0
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 ¶ added in v1.9.0
func (*UnimplementedAlertmanagerServer) ReadState(ctx context.Context, req *ReadStateRequest) (*ReadStateResponse, error)
func (*UnimplementedAlertmanagerServer) UpdateState ¶ added in v1.9.0
func (*UnimplementedAlertmanagerServer) UpdateState(ctx context.Context, req *clusterpb.Part) (*UpdateStateResponse, error)
type UpdateStateResponse ¶ added in v1.9.0
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 ¶ added in v1.9.0
func (*UpdateStateResponse) Descriptor() ([]byte, []int)
func (*UpdateStateResponse) Equal ¶ added in v1.9.0
func (this *UpdateStateResponse) Equal(that interface{}) bool
func (*UpdateStateResponse) GetError ¶ added in v1.9.0
func (m *UpdateStateResponse) GetError() string
func (*UpdateStateResponse) GetStatus ¶ added in v1.9.0
func (m *UpdateStateResponse) GetStatus() UpdateStateStatus
func (*UpdateStateResponse) GoString ¶ added in v1.9.0
func (this *UpdateStateResponse) GoString() string
func (*UpdateStateResponse) Marshal ¶ added in v1.9.0
func (m *UpdateStateResponse) Marshal() (dAtA []byte, err error)
func (*UpdateStateResponse) MarshalTo ¶ added in v1.9.0
func (m *UpdateStateResponse) MarshalTo(dAtA []byte) (int, error)
func (*UpdateStateResponse) MarshalToSizedBuffer ¶ added in v1.9.0
func (m *UpdateStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*UpdateStateResponse) ProtoMessage ¶ added in v1.9.0
func (*UpdateStateResponse) ProtoMessage()
func (*UpdateStateResponse) Reset ¶ added in v1.9.0
func (m *UpdateStateResponse) Reset()
func (*UpdateStateResponse) Size ¶ added in v1.9.0
func (m *UpdateStateResponse) Size() (n int)
func (*UpdateStateResponse) String ¶ added in v1.9.0
func (this *UpdateStateResponse) String() string
func (*UpdateStateResponse) Unmarshal ¶ added in v1.9.0
func (m *UpdateStateResponse) Unmarshal(dAtA []byte) error
func (*UpdateStateResponse) XXX_DiscardUnknown ¶ added in v1.9.0
func (m *UpdateStateResponse) XXX_DiscardUnknown()
func (*UpdateStateResponse) XXX_Marshal ¶ added in v1.9.0
func (m *UpdateStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpdateStateResponse) XXX_Merge ¶ added in v1.9.0
func (m *UpdateStateResponse) XXX_Merge(src proto.Message)
func (*UpdateStateResponse) XXX_Size ¶ added in v1.9.0
func (m *UpdateStateResponse) XXX_Size() int
func (*UpdateStateResponse) XXX_Unmarshal ¶ added in v1.9.0
func (m *UpdateStateResponse) XXX_Unmarshal(b []byte) error
type UpdateStateStatus ¶ added in v1.9.0
type UpdateStateStatus int32
const ( OK UpdateStateStatus = 0 MERGE_ERROR UpdateStateStatus = 2 USER_NOT_FOUND UpdateStateStatus = 3 )
func (UpdateStateStatus) EnumDescriptor ¶ added in v1.9.0
func (UpdateStateStatus) EnumDescriptor() ([]byte, []int)
func (UpdateStateStatus) String ¶ added in v1.9.0
func (x UpdateStateStatus) String() string
Click to show internal directories.
Click to hide internal directories.