optimusv1

package
v0.1.3-alpha Latest Latest
Warning

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

 Go to latest Published: Oct 21, 2024 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_optimus_v1_optimus_proto protoreflect.FileDescriptor
View Source 
var OptimusLogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "optimus.v1.OptimusLogService",
	HandlerType: (*OptimusLogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StoreLogEvent",
			Handler:    _OptimusLogService_StoreLogEvent_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "optimus/v1/optimus.proto",
}

OptimusLogService_ServiceDesc is the grpc.ServiceDesc for OptimusLogService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOptimusLogServiceServer 

func RegisterOptimusLogServiceServer(s grpc.ServiceRegistrar, srv OptimusLogServiceServer)

Types

type LogEvent 

type LogEvent struct {
	Id        string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Data      *structpb.Struct `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Source    string           `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Upstreams []string         `protobuf:"bytes,4,rep,name=upstreams,proto3" json:"upstreams,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEvent) Descriptor deprecated 

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

Deprecated: Use LogEvent.ProtoReflect.Descriptor instead.

func (*LogEvent) GetData 

func (x *LogEvent) GetData() *structpb.Struct

func (*LogEvent) GetId 

func (x *LogEvent) GetId() string

func (*LogEvent) GetSource 

func (x *LogEvent) GetSource() string

func (*LogEvent) GetUpstreams 

func (x *LogEvent) GetUpstreams() []string

func (*LogEvent) ProtoMessage 

func (*LogEvent) ProtoMessage()

func (*LogEvent) ProtoReflect 

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

func (*LogEvent) Reset 

func (x *LogEvent) Reset()

func (*LogEvent) String 

func (x *LogEvent) String() string

func (*LogEvent) Validate 

func (m *LogEvent) Validate() error

Validate checks the field values on LogEvent with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*LogEvent) ValidateAll 

func (m *LogEvent) ValidateAll() error

ValidateAll checks the field values on LogEvent with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LogEventMultiError, or nil if none found.

type LogEventMultiError 

type LogEventMultiError []error

LogEventMultiError is an error wrapping multiple validation errors returned by LogEvent.ValidateAll() if the designated constraints aren't met.

func (LogEventMultiError) AllErrors 

func (m LogEventMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogEventMultiError) Error 

func (m LogEventMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LogEventValidationError 

type LogEventValidationError struct {
	// contains filtered or unexported fields
}

LogEventValidationError is the validation error returned by LogEvent.Validate if the designated constraints aren't met.

func (LogEventValidationError) Cause 

func (e LogEventValidationError) Cause() error

Cause function returns cause value.

func (LogEventValidationError) Error 

func (e LogEventValidationError) Error() string

Error satisfies the builtin error interface

func (LogEventValidationError) ErrorName 

func (e LogEventValidationError) ErrorName() string

ErrorName returns error name.

func (LogEventValidationError) Field 

func (e LogEventValidationError) Field() string

Field function returns field value.

func (LogEventValidationError) Key 

func (e LogEventValidationError) Key() bool

Key function returns key value.

func (LogEventValidationError) Reason 

func (e LogEventValidationError) Reason() string

Reason function returns reason value.

type OptimusLogServiceClient 

type OptimusLogServiceClient interface {
	// Store saves an event(s) onto the processing pipeline
	StoreLogEvent(ctx context.Context, in *StoreLogEventRequest, opts ...grpc.CallOption) (*StoreLogEventResponse, error)
}

OptimusLogServiceClient is the client API for OptimusLogService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewOptimusLogServiceClient 

func NewOptimusLogServiceClient(cc grpc.ClientConnInterface) OptimusLogServiceClient

type OptimusLogServiceServer 

type OptimusLogServiceServer interface {
	// Store saves an event(s) onto the processing pipeline
	StoreLogEvent(context.Context, *StoreLogEventRequest) (*StoreLogEventResponse, error)
}

OptimusLogServiceServer is the server API for OptimusLogService service. All implementations should embed UnimplementedOptimusLogServiceServer for forward compatibility

type StoreLogEventRequest 

type StoreLogEventRequest struct {

	// key is an idempotency key
	Key    string             `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Events []*structpb.Struct `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreLogEventRequest) Descriptor deprecated 

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

Deprecated: Use StoreLogEventRequest.ProtoReflect.Descriptor instead.

func (*StoreLogEventRequest) GetEvents 

func (x *StoreLogEventRequest) GetEvents() []*structpb.Struct

func (*StoreLogEventRequest) GetKey 

func (x *StoreLogEventRequest) GetKey() string

func (*StoreLogEventRequest) ProtoMessage 

func (*StoreLogEventRequest) ProtoMessage()

func (*StoreLogEventRequest) ProtoReflect 

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

func (*StoreLogEventRequest) Reset 

func (x *StoreLogEventRequest) Reset()

func (*StoreLogEventRequest) String 

func (x *StoreLogEventRequest) String() string

func (*StoreLogEventRequest) Validate 

func (m *StoreLogEventRequest) Validate() error

Validate checks the field values on StoreLogEventRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StoreLogEventRequest) ValidateAll 

func (m *StoreLogEventRequest) ValidateAll() error

ValidateAll checks the field values on StoreLogEventRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StoreLogEventRequestMultiError, or nil if none found.

type StoreLogEventRequestMultiError 

type StoreLogEventRequestMultiError []error

StoreLogEventRequestMultiError is an error wrapping multiple validation errors returned by StoreLogEventRequest.ValidateAll() if the designated constraints aren't met.

func (StoreLogEventRequestMultiError) AllErrors 

func (m StoreLogEventRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StoreLogEventRequestMultiError) Error 

func (m StoreLogEventRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type StoreLogEventRequestValidationError 

type StoreLogEventRequestValidationError struct {
	// contains filtered or unexported fields
}

StoreLogEventRequestValidationError is the validation error returned by StoreLogEventRequest.Validate if the designated constraints aren't met.

func (StoreLogEventRequestValidationError) Cause 

func (e StoreLogEventRequestValidationError) Cause() error

Cause function returns cause value.

func (StoreLogEventRequestValidationError) Error 

func (e StoreLogEventRequestValidationError) Error() string

Error satisfies the builtin error interface

func (StoreLogEventRequestValidationError) ErrorName 

func (e StoreLogEventRequestValidationError) ErrorName() string

ErrorName returns error name.

func (StoreLogEventRequestValidationError) Field 

func (e StoreLogEventRequestValidationError) Field() string

Field function returns field value.

func (StoreLogEventRequestValidationError) Key 

func (e StoreLogEventRequestValidationError) Key() bool

Key function returns key value.

func (StoreLogEventRequestValidationError) Reason 

func (e StoreLogEventRequestValidationError) Reason() string

Reason function returns reason value.

type StoreLogEventResponse 

type StoreLogEventResponse struct {
	EventIds []string `protobuf:"bytes,1,rep,name=event_ids,json=eventIds,proto3" json:"event_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreLogEventResponse) Descriptor deprecated 

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

Deprecated: Use StoreLogEventResponse.ProtoReflect.Descriptor instead.

func (*StoreLogEventResponse) GetEventIds 

func (x *StoreLogEventResponse) GetEventIds() []string

func (*StoreLogEventResponse) ProtoMessage 

func (*StoreLogEventResponse) ProtoMessage()

func (*StoreLogEventResponse) ProtoReflect 

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

func (*StoreLogEventResponse) Reset 

func (x *StoreLogEventResponse) Reset()

func (*StoreLogEventResponse) String 

func (x *StoreLogEventResponse) String() string

func (*StoreLogEventResponse) Validate 

func (m *StoreLogEventResponse) Validate() error

Validate checks the field values on StoreLogEventResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*StoreLogEventResponse) ValidateAll 

func (m *StoreLogEventResponse) ValidateAll() error

ValidateAll checks the field values on StoreLogEventResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in StoreLogEventResponseMultiError, or nil if none found.

type StoreLogEventResponseMultiError 

type StoreLogEventResponseMultiError []error

StoreLogEventResponseMultiError is an error wrapping multiple validation errors returned by StoreLogEventResponse.ValidateAll() if the designated constraints aren't met.

func (StoreLogEventResponseMultiError) AllErrors 

func (m StoreLogEventResponseMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (StoreLogEventResponseMultiError) Error 

func (m StoreLogEventResponseMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type StoreLogEventResponseValidationError 

type StoreLogEventResponseValidationError struct {
	// contains filtered or unexported fields
}

StoreLogEventResponseValidationError is the validation error returned by StoreLogEventResponse.Validate if the designated constraints aren't met.

func (StoreLogEventResponseValidationError) Cause 

func (e StoreLogEventResponseValidationError) Cause() error

Cause function returns cause value.

func (StoreLogEventResponseValidationError) Error 

func (e StoreLogEventResponseValidationError) Error() string

Error satisfies the builtin error interface

func (StoreLogEventResponseValidationError) ErrorName 

func (e StoreLogEventResponseValidationError) ErrorName() string

ErrorName returns error name.

func (StoreLogEventResponseValidationError) Field 

func (e StoreLogEventResponseValidationError) Field() string

Field function returns field value.

func (StoreLogEventResponseValidationError) Key 

func (e StoreLogEventResponseValidationError) Key() bool

Key function returns key value.

func (StoreLogEventResponseValidationError) Reason 

func (e StoreLogEventResponseValidationError) Reason() string

Reason function returns reason value.

type UnimplementedOptimusLogServiceServer 

type UnimplementedOptimusLogServiceServer struct {
}

UnimplementedOptimusLogServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedOptimusLogServiceServer) StoreLogEvent 

func (UnimplementedOptimusLogServiceServer) StoreLogEvent(context.Context, *StoreLogEventRequest) (*StoreLogEventResponse, error)

type UnsafeOptimusLogServiceServer 

type UnsafeOptimusLogServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeOptimusLogServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OptimusLogServiceServer will result in compilation errors.

Source Files

View all Source files

Directories

Path Synopsis

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.