accesslogv3grpc

Documentation

Index

• Constants
• Variables
• func RegisterAccessLogServiceServer(s grpc.ServiceRegistrar, srv AccessLogServiceServer)
• type AccessLogServiceClient
  • func NewAccessLogServiceClient(cc grpc.ClientConnInterface) AccessLogServiceClient
• type AccessLogServiceServer
• type AccessLogService_StreamAccessLogsClient
• type AccessLogService_StreamAccessLogsServer
• type UnimplementedAccessLogServiceServer
  • func (UnimplementedAccessLogServiceServer) StreamAccessLogs(AccessLogService_StreamAccessLogsServer) error
• type UnsafeAccessLogServiceServer

Constants

const (
	AccessLogService_StreamAccessLogs_FullMethodName = "/envoy.service.accesslog.v3.AccessLogService/StreamAccessLogs"
)

Variables

var AccessLogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "envoy.service.accesslog.v3.AccessLogService",
	HandlerType: (*AccessLogServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamAccessLogs",
			Handler:       _AccessLogService_StreamAccessLogs_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "envoy/service/accesslog/v3/als.proto",
}

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

Functions

func RegisterAccessLogServiceServer

func RegisterAccessLogServiceServer(s grpc.ServiceRegistrar, srv AccessLogServiceServer)

Types

type AccessLogServiceClient

type AccessLogServiceClient interface {
	// Envoy will connect and send StreamAccessLogsMessage messages forever. It does not expect any
	// response to be sent as nothing would be done in the case of failure. The server should
	// disconnect if it expects Envoy to reconnect. In the future we may decide to add a different
	// API for "critical" access logs in which Envoy will buffer access logs for some period of time
	// until it gets an ACK so it could then retry. This API is designed for high throughput with the
	// expectation that it might be lossy.
	StreamAccessLogs(ctx context.Context, opts ...grpc.CallOption) (AccessLogService_StreamAccessLogsClient, error)
}

AccessLogServiceClient is the client API for AccessLogService 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 NewAccessLogServiceClient

func NewAccessLogServiceClient(cc grpc.ClientConnInterface) AccessLogServiceClient

type AccessLogServiceServer

type AccessLogServiceServer interface {
	// Envoy will connect and send StreamAccessLogsMessage messages forever. It does not expect any
	// response to be sent as nothing would be done in the case of failure. The server should
	// disconnect if it expects Envoy to reconnect. In the future we may decide to add a different
	// API for "critical" access logs in which Envoy will buffer access logs for some period of time
	// until it gets an ACK so it could then retry. This API is designed for high throughput with the
	// expectation that it might be lossy.
	StreamAccessLogs(AccessLogService_StreamAccessLogsServer) error
}

AccessLogServiceServer is the server API for AccessLogService service. All implementations should embed UnimplementedAccessLogServiceServer for forward compatibility

type AccessLogService_StreamAccessLogsClient

type AccessLogService_StreamAccessLogsClient interface {
	Send(*v3.StreamAccessLogsMessage) error
	CloseAndRecv() (*v3.StreamAccessLogsResponse, error)
	grpc.ClientStream
}

type AccessLogService_StreamAccessLogsServer

type AccessLogService_StreamAccessLogsServer interface {
	SendAndClose(*v3.StreamAccessLogsResponse) error
	Recv() (*v3.StreamAccessLogsMessage, error)
	grpc.ServerStream
}

type UnimplementedAccessLogServiceServer

type UnimplementedAccessLogServiceServer struct {
}

UnimplementedAccessLogServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedAccessLogServiceServer) StreamAccessLogs

func (UnimplementedAccessLogServiceServer) StreamAccessLogs(AccessLogService_StreamAccessLogsServer) error

type UnsafeAccessLogServiceServer

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

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