log_client

package
v1.9.1 Latest Latest
Warning

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

Go to latest
Published: Dec 19, 2024 License: Apache-2.0 Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateLogsDescriptor

type CreateLogsDescriptor struct{}

func GetCreateLogsDescriptor

func GetCreateLogsDescriptor() *CreateLogsDescriptor

func (*CreateLogsDescriptor) GetApiDescriptor

func (d *CreateLogsDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*CreateLogsDescriptor) GetApiName

func (d *CreateLogsDescriptor) GetApiName() string

func (*CreateLogsDescriptor) GetClientMsgReflectHandle

func (d *CreateLogsDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*CreateLogsDescriptor) GetFullMethodName

func (d *CreateLogsDescriptor) GetFullMethodName() string

func (*CreateLogsDescriptor) GetMethodName

func (d *CreateLogsDescriptor) GetMethodName() string

func (*CreateLogsDescriptor) GetProtoPkgName

func (d *CreateLogsDescriptor) GetProtoPkgName() string

func (*CreateLogsDescriptor) GetResourceDescriptor

func (d *CreateLogsDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*CreateLogsDescriptor) GetServerMsgReflectHandle

func (d *CreateLogsDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*CreateLogsDescriptor) GetServiceDomain

func (d *CreateLogsDescriptor) GetServiceDomain() string

func (*CreateLogsDescriptor) GetServiceVersion

func (d *CreateLogsDescriptor) GetServiceVersion() string

func (*CreateLogsDescriptor) GetVerb

func (d *CreateLogsDescriptor) GetVerb() string

func (*CreateLogsDescriptor) HasResource

func (d *CreateLogsDescriptor) HasResource() bool

func (*CreateLogsDescriptor) IsClientStream

func (d *CreateLogsDescriptor) IsClientStream() bool

func (*CreateLogsDescriptor) IsCollection

func (d *CreateLogsDescriptor) IsCollection() bool

func (*CreateLogsDescriptor) IsPlural

func (d *CreateLogsDescriptor) IsPlural() bool

func (*CreateLogsDescriptor) IsServerStream

func (d *CreateLogsDescriptor) IsServerStream() bool

func (*CreateLogsDescriptor) IsUnary

func (d *CreateLogsDescriptor) IsUnary() bool

func (*CreateLogsDescriptor) NewEmptyClientMsg

func (d *CreateLogsDescriptor) NewEmptyClientMsg() proto.Message

func (*CreateLogsDescriptor) NewEmptyServerMsg

func (d *CreateLogsDescriptor) NewEmptyServerMsg() proto.Message

func (*CreateLogsDescriptor) RequestHasResourceBody

func (d *CreateLogsDescriptor) RequestHasResourceBody() bool

type CreateLogsDescriptorClientMsgHandle

type CreateLogsDescriptorClientMsgHandle struct{}

func (*CreateLogsDescriptorClientMsgHandle) ExtractCollectionName

func (h *CreateLogsDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*CreateLogsDescriptorClientMsgHandle) ExtractResourceBodies

func (*CreateLogsDescriptorClientMsgHandle) ExtractResourceBody

func (*CreateLogsDescriptorClientMsgHandle) ExtractResourceName

func (*CreateLogsDescriptorClientMsgHandle) ExtractResourceNames

type CreateLogsDescriptorServerMsgHandle

type CreateLogsDescriptorServerMsgHandle struct{}

func (*CreateLogsDescriptorServerMsgHandle) ExtractCollectionName

func (h *CreateLogsDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*CreateLogsDescriptorServerMsgHandle) ExtractResourceBodies

func (*CreateLogsDescriptorServerMsgHandle) ExtractResourceBody

func (*CreateLogsDescriptorServerMsgHandle) ExtractResourceName

func (*CreateLogsDescriptorServerMsgHandle) ExtractResourceNames

type CreateLogsRequest

type CreateLogsRequest struct {

	// Parent reference of ntt.logging.v1.Log
	Parent *log.ParentName `protobuf:"bytes,1,opt,customtype=ParentName,name=parent,proto3" json:"parent,omitempty" firestore:"parent"`
	// List of logs to create/append. If they have specified name
	// field, it must match provided parent field.
	Logs []*log.Log `protobuf:"bytes,2,rep,name=logs,proto3" json:"logs,omitempty" firestore:"logs"`
	// contains filtered or unexported fields
}

Request message for method [CreateLogs][ntt.logging.v1.CreateLogs]

func (*CreateLogsRequest) Descriptor

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

Deprecated, Use CreateLogsRequest.ProtoReflect.Descriptor instead.

func (*CreateLogsRequest) GetLogs

func (m *CreateLogsRequest) GetLogs() []*log.Log

func (*CreateLogsRequest) GetParent

func (m *CreateLogsRequest) GetParent() *log.ParentName

func (*CreateLogsRequest) GotenMessage

func (*CreateLogsRequest) GotenMessage()

func (*CreateLogsRequest) GotenValidate

func (obj *CreateLogsRequest) GotenValidate() error

func (*CreateLogsRequest) Marshal

func (m *CreateLogsRequest) Marshal() ([]byte, error)

func (*CreateLogsRequest) MarshalJSON

func (m *CreateLogsRequest) MarshalJSON() ([]byte, error)

func (*CreateLogsRequest) ProtoMessage

func (*CreateLogsRequest) ProtoMessage()

func (*CreateLogsRequest) ProtoReflect

func (m *CreateLogsRequest) ProtoReflect() preflect.Message

func (*CreateLogsRequest) Reset

func (m *CreateLogsRequest) Reset()

func (*CreateLogsRequest) SetLogs

func (m *CreateLogsRequest) SetLogs(fv []*log.Log)

func (*CreateLogsRequest) SetParent

func (m *CreateLogsRequest) SetParent(fv *log.ParentName)

func (*CreateLogsRequest) String

func (m *CreateLogsRequest) String() string

func (*CreateLogsRequest) Unmarshal

func (m *CreateLogsRequest) Unmarshal(b []byte) error

func (*CreateLogsRequest) UnmarshalJSON

func (m *CreateLogsRequest) UnmarshalJSON(data []byte) error

type CreateLogsResponse

type CreateLogsResponse struct {

	// Log names indexed by Create position. All logs, except
	// failed ones will be present. If all logs were written successfully,
	// then map will have keys all from 0 to N-1.
	LogNames map[uint32]*log.Name `` /* 227-byte string literal not displayed */
	// Logs that failed to be created
	FailedLogs []*CreateLogsResponse_CreateError `protobuf:"bytes,2,rep,name=failed_logs,json=failedLogs,proto3" json:"failed_logs,omitempty" firestore:"failedLogs"`
	// contains filtered or unexported fields
}

Response message for method [CreateLogs][ntt.logging.v1.CreateLogs]

func (*CreateLogsResponse) Descriptor

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

Deprecated, Use CreateLogsResponse.ProtoReflect.Descriptor instead.

func (*CreateLogsResponse) GetFailedLogs

func (m *CreateLogsResponse) GetFailedLogs() []*CreateLogsResponse_CreateError

func (*CreateLogsResponse) GetLogNames

func (m *CreateLogsResponse) GetLogNames() map[uint32]*log.Name

func (*CreateLogsResponse) GotenMessage

func (*CreateLogsResponse) GotenMessage()

func (*CreateLogsResponse) GotenValidate

func (obj *CreateLogsResponse) GotenValidate() error

func (*CreateLogsResponse) Marshal

func (m *CreateLogsResponse) Marshal() ([]byte, error)

func (*CreateLogsResponse) MarshalJSON

func (m *CreateLogsResponse) MarshalJSON() ([]byte, error)

func (*CreateLogsResponse) ProtoMessage

func (*CreateLogsResponse) ProtoMessage()

func (*CreateLogsResponse) ProtoReflect

func (m *CreateLogsResponse) ProtoReflect() preflect.Message

func (*CreateLogsResponse) Reset

func (m *CreateLogsResponse) Reset()

func (*CreateLogsResponse) SetFailedLogs

func (m *CreateLogsResponse) SetFailedLogs(fv []*CreateLogsResponse_CreateError)

func (*CreateLogsResponse) SetLogNames

func (m *CreateLogsResponse) SetLogNames(fv map[uint32]*log.Name)

func (*CreateLogsResponse) String

func (m *CreateLogsResponse) String() string

func (*CreateLogsResponse) Unmarshal

func (m *CreateLogsResponse) Unmarshal(b []byte) error

func (*CreateLogsResponse) UnmarshalJSON

func (m *CreateLogsResponse) UnmarshalJSON(data []byte) error

type CreateLogsResponse_CreateError

type CreateLogsResponse_CreateError struct {

	// All logs that failed to be written. This field provides all of
	// the context that would be needed to retry the operation.
	Logs []*log.Log `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty" firestore:"logs"`
	// The status of the requested write operation.
	Status *rpc.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty" firestore:"status"`
	// contains filtered or unexported fields
}

Describes the result of a failed request to write logs.

func (*CreateLogsResponse_CreateError) Descriptor

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

Deprecated, Use CreateLogsResponse_CreateError.ProtoReflect.Descriptor instead.

func (*CreateLogsResponse_CreateError) GetLogs

func (m *CreateLogsResponse_CreateError) GetLogs() []*log.Log

func (*CreateLogsResponse_CreateError) GetStatus

func (m *CreateLogsResponse_CreateError) GetStatus() *rpc.Status

func (*CreateLogsResponse_CreateError) GotenMessage

func (*CreateLogsResponse_CreateError) GotenMessage()

func (*CreateLogsResponse_CreateError) GotenValidate

func (obj *CreateLogsResponse_CreateError) GotenValidate() error

func (*CreateLogsResponse_CreateError) Marshal

func (m *CreateLogsResponse_CreateError) Marshal() ([]byte, error)

func (*CreateLogsResponse_CreateError) MarshalJSON

func (m *CreateLogsResponse_CreateError) MarshalJSON() ([]byte, error)

func (*CreateLogsResponse_CreateError) ProtoMessage

func (*CreateLogsResponse_CreateError) ProtoMessage()

func (*CreateLogsResponse_CreateError) ProtoReflect

func (*CreateLogsResponse_CreateError) Reset

func (m *CreateLogsResponse_CreateError) Reset()

func (*CreateLogsResponse_CreateError) SetLogs

func (m *CreateLogsResponse_CreateError) SetLogs(fv []*log.Log)

func (*CreateLogsResponse_CreateError) SetStatus

func (m *CreateLogsResponse_CreateError) SetStatus(fv *rpc.Status)

func (*CreateLogsResponse_CreateError) String

func (*CreateLogsResponse_CreateError) Unmarshal

func (m *CreateLogsResponse_CreateError) Unmarshal(b []byte) error

func (*CreateLogsResponse_CreateError) UnmarshalJSON

func (m *CreateLogsResponse_CreateError) UnmarshalJSON(data []byte) error

type ListLogsDescriptor

type ListLogsDescriptor struct{}

func GetListLogsDescriptor

func GetListLogsDescriptor() *ListLogsDescriptor

func (*ListLogsDescriptor) GetApiDescriptor

func (d *ListLogsDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*ListLogsDescriptor) GetApiName

func (d *ListLogsDescriptor) GetApiName() string

func (*ListLogsDescriptor) GetClientMsgReflectHandle

func (d *ListLogsDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*ListLogsDescriptor) GetFullMethodName

func (d *ListLogsDescriptor) GetFullMethodName() string

func (*ListLogsDescriptor) GetMethodName

func (d *ListLogsDescriptor) GetMethodName() string

func (*ListLogsDescriptor) GetProtoPkgName

func (d *ListLogsDescriptor) GetProtoPkgName() string

func (*ListLogsDescriptor) GetResourceDescriptor

func (d *ListLogsDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*ListLogsDescriptor) GetServerMsgReflectHandle

func (d *ListLogsDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*ListLogsDescriptor) GetServiceDomain

func (d *ListLogsDescriptor) GetServiceDomain() string

func (*ListLogsDescriptor) GetServiceVersion

func (d *ListLogsDescriptor) GetServiceVersion() string

func (*ListLogsDescriptor) GetVerb

func (d *ListLogsDescriptor) GetVerb() string

func (*ListLogsDescriptor) HasResource

func (d *ListLogsDescriptor) HasResource() bool

func (*ListLogsDescriptor) IsClientStream

func (d *ListLogsDescriptor) IsClientStream() bool

func (*ListLogsDescriptor) IsCollection

func (d *ListLogsDescriptor) IsCollection() bool

func (*ListLogsDescriptor) IsPlural

func (d *ListLogsDescriptor) IsPlural() bool

func (*ListLogsDescriptor) IsServerStream

func (d *ListLogsDescriptor) IsServerStream() bool

func (*ListLogsDescriptor) IsUnary

func (d *ListLogsDescriptor) IsUnary() bool

func (*ListLogsDescriptor) NewEmptyClientMsg

func (d *ListLogsDescriptor) NewEmptyClientMsg() proto.Message

func (*ListLogsDescriptor) NewEmptyServerMsg

func (d *ListLogsDescriptor) NewEmptyServerMsg() proto.Message

func (*ListLogsDescriptor) RequestHasResourceBody

func (d *ListLogsDescriptor) RequestHasResourceBody() bool

type ListLogsDescriptorClientMsgHandle

type ListLogsDescriptorClientMsgHandle struct{}

func (*ListLogsDescriptorClientMsgHandle) ExtractCollectionName

func (h *ListLogsDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*ListLogsDescriptorClientMsgHandle) ExtractResourceBodies

func (*ListLogsDescriptorClientMsgHandle) ExtractResourceBody

func (*ListLogsDescriptorClientMsgHandle) ExtractResourceName

func (*ListLogsDescriptorClientMsgHandle) ExtractResourceNames

type ListLogsDescriptorServerMsgHandle

type ListLogsDescriptorServerMsgHandle struct{}

func (*ListLogsDescriptorServerMsgHandle) ExtractCollectionName

func (h *ListLogsDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*ListLogsDescriptorServerMsgHandle) ExtractResourceBodies

func (*ListLogsDescriptorServerMsgHandle) ExtractResourceBody

func (*ListLogsDescriptorServerMsgHandle) ExtractResourceName

func (*ListLogsDescriptorServerMsgHandle) ExtractResourceNames

type ListLogsRequest

type ListLogsRequest struct {

	// Parent references of ntt.logging.v1.Log
	Parents []*log.ParentName `protobuf:"bytes,1,rep,customtype=ParentName,name=parents,proto3" json:"parents,omitempty" firestore:"parents"`
	// Filter that specifies which logs should be returned
	Filter *log.Filter `protobuf:"bytes,2,opt,customtype=Filter,name=filter,proto3" json:"filter,omitempty" firestore:"filter"`
	// The time interval for which results should be returned. Only logs
	// that contain data points in the specified interval are included
	// in the response.
	Interval *common.TimeInterval `protobuf:"bytes,3,opt,name=interval,proto3" json:"interval,omitempty" firestore:"interval"`
	// Cap on a number of log entries to be included in a response.
	// Number of logs in an actual response can be higher, since logs are
	// read in bulk with second precision - exceed logs above the limit will share
	// same timestamp as the logs below the limit.
	//
	// Results will be adjusted to the "end time" taken from interval field
	// (adjusted also by page_token if provided).
	PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty" firestore:"pageSize"`
	// Token which identifies next page with further results. Token should be
	// taken from
	// [ListLogsResponse.next_page_token][ntt.logging.v1.ListLogsResponse.next_page_token].
	PageToken string `protobuf:"bytes,6,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty" firestore:"pageToken"`
	// contains filtered or unexported fields
}

Request message for method [ListLogs][ntt.logging.v1.ListLogs]

func (*ListLogsRequest) Descriptor

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

Deprecated, Use ListLogsRequest.ProtoReflect.Descriptor instead.

func (*ListLogsRequest) GetFilter

func (m *ListLogsRequest) GetFilter() *log.Filter

func (*ListLogsRequest) GetInterval

func (m *ListLogsRequest) GetInterval() *common.TimeInterval

func (*ListLogsRequest) GetPageSize

func (m *ListLogsRequest) GetPageSize() int32

func (*ListLogsRequest) GetPageToken

func (m *ListLogsRequest) GetPageToken() string

func (*ListLogsRequest) GetParents

func (m *ListLogsRequest) GetParents() []*log.ParentName

func (*ListLogsRequest) GotenMessage

func (*ListLogsRequest) GotenMessage()

func (*ListLogsRequest) GotenValidate

func (obj *ListLogsRequest) GotenValidate() error

func (*ListLogsRequest) Marshal

func (m *ListLogsRequest) Marshal() ([]byte, error)

func (*ListLogsRequest) MarshalJSON

func (m *ListLogsRequest) MarshalJSON() ([]byte, error)

func (*ListLogsRequest) ProtoMessage

func (*ListLogsRequest) ProtoMessage()

func (*ListLogsRequest) ProtoReflect

func (m *ListLogsRequest) ProtoReflect() preflect.Message

func (*ListLogsRequest) Reset

func (m *ListLogsRequest) Reset()

func (*ListLogsRequest) SetFilter

func (m *ListLogsRequest) SetFilter(fv *log.Filter)

func (*ListLogsRequest) SetInterval

func (m *ListLogsRequest) SetInterval(fv *common.TimeInterval)

func (*ListLogsRequest) SetPageSize

func (m *ListLogsRequest) SetPageSize(fv int32)

func (*ListLogsRequest) SetPageToken

func (m *ListLogsRequest) SetPageToken(fv string)

func (*ListLogsRequest) SetParents

func (m *ListLogsRequest) SetParents(fv []*log.ParentName)

func (*ListLogsRequest) String

func (m *ListLogsRequest) String() string

func (*ListLogsRequest) Unmarshal

func (m *ListLogsRequest) Unmarshal(b []byte) error

func (*ListLogsRequest) UnmarshalJSON

func (m *ListLogsRequest) UnmarshalJSON(data []byte) error

type ListLogsResponse

type ListLogsResponse struct {

	// Logs that match the filter included in the request.
	Logs []*log.Log `protobuf:"bytes,1,rep,name=logs,proto3" json:"logs,omitempty" firestore:"logs"`
	// If there are more results than have been returned, then this field is set
	// to a non-empty value. To see the additional results,
	// use that value as `pageToken` in the next call to this method.
	NextPageToken string `` /* 128-byte string literal not displayed */
	// Query execution errors that may have caused the logs data returned
	// to be incomplete.
	ExecutionErrors []*rpc.Status `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

Response message for method [ListLogs][ntt.logging.v1.ListLogs]

func (*ListLogsResponse) Descriptor

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

Deprecated, Use ListLogsResponse.ProtoReflect.Descriptor instead.

func (*ListLogsResponse) GetExecutionErrors

func (m *ListLogsResponse) GetExecutionErrors() []*rpc.Status

func (*ListLogsResponse) GetLogs

func (m *ListLogsResponse) GetLogs() []*log.Log

func (*ListLogsResponse) GetNextPageToken

func (m *ListLogsResponse) GetNextPageToken() string

func (*ListLogsResponse) GotenMessage

func (*ListLogsResponse) GotenMessage()

func (*ListLogsResponse) GotenValidate

func (obj *ListLogsResponse) GotenValidate() error

func (*ListLogsResponse) Marshal

func (m *ListLogsResponse) Marshal() ([]byte, error)

func (*ListLogsResponse) MarshalJSON

func (m *ListLogsResponse) MarshalJSON() ([]byte, error)

func (*ListLogsResponse) ProtoMessage

func (*ListLogsResponse) ProtoMessage()

func (*ListLogsResponse) ProtoReflect

func (m *ListLogsResponse) ProtoReflect() preflect.Message

func (*ListLogsResponse) Reset

func (m *ListLogsResponse) Reset()

func (*ListLogsResponse) SetExecutionErrors

func (m *ListLogsResponse) SetExecutionErrors(fv []*rpc.Status)

func (*ListLogsResponse) SetLogs

func (m *ListLogsResponse) SetLogs(fv []*log.Log)

func (*ListLogsResponse) SetNextPageToken

func (m *ListLogsResponse) SetNextPageToken(fv string)

func (*ListLogsResponse) String

func (m *ListLogsResponse) String() string

func (*ListLogsResponse) Unmarshal

func (m *ListLogsResponse) Unmarshal(b []byte) error

func (*ListLogsResponse) UnmarshalJSON

func (m *ListLogsResponse) UnmarshalJSON(data []byte) error

type ListLogsResponse_ErrorDetails

type ListLogsResponse_ErrorDetails struct {

	// region id which failed to give results.
	RegionId string `protobuf:"bytes,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty" firestore:"regionId"`
	// contains filtered or unexported fields
}

ErrorDetails is used when one of the queried regions fails to produce results. It is used in execution_errors field (see subfield ntt.rpc.Status.details).

func (*ListLogsResponse_ErrorDetails) Descriptor

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

Deprecated, Use ListLogsResponse_ErrorDetails.ProtoReflect.Descriptor instead.

func (*ListLogsResponse_ErrorDetails) GetRegionId

func (m *ListLogsResponse_ErrorDetails) GetRegionId() string

func (*ListLogsResponse_ErrorDetails) GotenMessage

func (*ListLogsResponse_ErrorDetails) GotenMessage()

func (*ListLogsResponse_ErrorDetails) GotenValidate

func (obj *ListLogsResponse_ErrorDetails) GotenValidate() error

func (*ListLogsResponse_ErrorDetails) Marshal

func (m *ListLogsResponse_ErrorDetails) Marshal() ([]byte, error)

func (*ListLogsResponse_ErrorDetails) MarshalJSON

func (m *ListLogsResponse_ErrorDetails) MarshalJSON() ([]byte, error)

func (*ListLogsResponse_ErrorDetails) ProtoMessage

func (*ListLogsResponse_ErrorDetails) ProtoMessage()

func (*ListLogsResponse_ErrorDetails) ProtoReflect

func (*ListLogsResponse_ErrorDetails) Reset

func (m *ListLogsResponse_ErrorDetails) Reset()

func (*ListLogsResponse_ErrorDetails) SetRegionId

func (m *ListLogsResponse_ErrorDetails) SetRegionId(fv string)

func (*ListLogsResponse_ErrorDetails) String

func (*ListLogsResponse_ErrorDetails) Unmarshal

func (m *ListLogsResponse_ErrorDetails) Unmarshal(b []byte) error

func (*ListLogsResponse_ErrorDetails) UnmarshalJSON

func (m *ListLogsResponse_ErrorDetails) UnmarshalJSON(data []byte) error

type LogServiceClient

type LogServiceClient interface {
	ListLogs(ctx context.Context, in *ListLogsRequest, opts ...grpc.CallOption) (*ListLogsResponse, error)
	CreateLogs(ctx context.Context, in *CreateLogsRequest, opts ...grpc.CallOption) (*CreateLogsResponse, error)
	StreamingCreateLogs(ctx context.Context, opts ...grpc.CallOption) (StreamingCreateLogsClientStream, error)
}

LogServiceClient is the client API for LogService.

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

func NewLogServiceClient

func NewLogServiceClient(cc grpc.ClientConnInterface) LogServiceClient

type LogServiceDescriptor

type LogServiceDescriptor struct{}

func GetLogServiceDescriptor

func GetLogServiceDescriptor() *LogServiceDescriptor

func (*LogServiceDescriptor) AllMethodDescriptors

func (d *LogServiceDescriptor) AllMethodDescriptors() []gotenclient.MethodDescriptor

func (*LogServiceDescriptor) GetApiName

func (d *LogServiceDescriptor) GetApiName() string

func (*LogServiceDescriptor) GetFullAPIName

func (d *LogServiceDescriptor) GetFullAPIName() string

func (*LogServiceDescriptor) GetProtoPkgName

func (d *LogServiceDescriptor) GetProtoPkgName() string

func (*LogServiceDescriptor) GetServiceDomain

func (d *LogServiceDescriptor) GetServiceDomain() string

func (*LogServiceDescriptor) GetServiceVersion

func (d *LogServiceDescriptor) GetServiceVersion() string

type StreamingCreateLogsClientStream added in v1.8.3

type StreamingCreateLogsClientStream interface {
	Send(*StreamingCreateLogsRequest) error
	Recv() (*StreamingCreateLogsResponse, error)
	grpc.ClientStream
}

type StreamingCreateLogsDescriptor added in v1.8.3

type StreamingCreateLogsDescriptor struct{}

func GetStreamingCreateLogsDescriptor added in v1.8.3

func GetStreamingCreateLogsDescriptor() *StreamingCreateLogsDescriptor

func (*StreamingCreateLogsDescriptor) GetApiDescriptor added in v1.8.3

func (*StreamingCreateLogsDescriptor) GetApiName added in v1.8.3

func (d *StreamingCreateLogsDescriptor) GetApiName() string

func (*StreamingCreateLogsDescriptor) GetClientMsgReflectHandle added in v1.8.3

func (d *StreamingCreateLogsDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*StreamingCreateLogsDescriptor) GetFullMethodName added in v1.8.3

func (d *StreamingCreateLogsDescriptor) GetFullMethodName() string

func (*StreamingCreateLogsDescriptor) GetMethodName added in v1.8.3

func (d *StreamingCreateLogsDescriptor) GetMethodName() string

func (*StreamingCreateLogsDescriptor) GetProtoPkgName added in v1.8.3

func (d *StreamingCreateLogsDescriptor) GetProtoPkgName() string

func (*StreamingCreateLogsDescriptor) GetResourceDescriptor added in v1.8.3

func (d *StreamingCreateLogsDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*StreamingCreateLogsDescriptor) GetServerMsgReflectHandle added in v1.8.3

func (d *StreamingCreateLogsDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*StreamingCreateLogsDescriptor) GetServiceDomain added in v1.8.3

func (d *StreamingCreateLogsDescriptor) GetServiceDomain() string

func (*StreamingCreateLogsDescriptor) GetServiceVersion added in v1.8.3

func (d *StreamingCreateLogsDescriptor) GetServiceVersion() string

func (*StreamingCreateLogsDescriptor) GetVerb added in v1.8.3

func (*StreamingCreateLogsDescriptor) HasResource added in v1.8.3

func (d *StreamingCreateLogsDescriptor) HasResource() bool

func (*StreamingCreateLogsDescriptor) IsClientStream added in v1.8.3

func (d *StreamingCreateLogsDescriptor) IsClientStream() bool

func (*StreamingCreateLogsDescriptor) IsCollection added in v1.8.3

func (d *StreamingCreateLogsDescriptor) IsCollection() bool

func (*StreamingCreateLogsDescriptor) IsPlural added in v1.8.3

func (d *StreamingCreateLogsDescriptor) IsPlural() bool

func (*StreamingCreateLogsDescriptor) IsServerStream added in v1.8.3

func (d *StreamingCreateLogsDescriptor) IsServerStream() bool

func (*StreamingCreateLogsDescriptor) IsUnary added in v1.8.3

func (d *StreamingCreateLogsDescriptor) IsUnary() bool

func (*StreamingCreateLogsDescriptor) NewEmptyClientMsg added in v1.8.3

func (d *StreamingCreateLogsDescriptor) NewEmptyClientMsg() proto.Message

func (*StreamingCreateLogsDescriptor) NewEmptyServerMsg added in v1.8.3

func (d *StreamingCreateLogsDescriptor) NewEmptyServerMsg() proto.Message

func (*StreamingCreateLogsDescriptor) RequestHasResourceBody added in v1.8.3

func (d *StreamingCreateLogsDescriptor) RequestHasResourceBody() bool

type StreamingCreateLogsDescriptorClientMsgHandle added in v1.8.3

type StreamingCreateLogsDescriptorClientMsgHandle struct{}

func (*StreamingCreateLogsDescriptorClientMsgHandle) ExtractCollectionName added in v1.8.3

func (*StreamingCreateLogsDescriptorClientMsgHandle) ExtractResourceBodies added in v1.8.3

func (*StreamingCreateLogsDescriptorClientMsgHandle) ExtractResourceBody added in v1.8.3

func (*StreamingCreateLogsDescriptorClientMsgHandle) ExtractResourceName added in v1.8.3

func (*StreamingCreateLogsDescriptorClientMsgHandle) ExtractResourceNames added in v1.8.3

type StreamingCreateLogsDescriptorServerMsgHandle added in v1.8.3

type StreamingCreateLogsDescriptorServerMsgHandle struct{}

func (*StreamingCreateLogsDescriptorServerMsgHandle) ExtractCollectionName added in v1.8.3

func (*StreamingCreateLogsDescriptorServerMsgHandle) ExtractResourceBodies added in v1.8.3

func (*StreamingCreateLogsDescriptorServerMsgHandle) ExtractResourceBody added in v1.8.3

func (*StreamingCreateLogsDescriptorServerMsgHandle) ExtractResourceName added in v1.8.3

func (*StreamingCreateLogsDescriptorServerMsgHandle) ExtractResourceNames added in v1.8.3

type StreamingCreateLogsRequest added in v1.8.3

type StreamingCreateLogsRequest struct {

	// Parent reference of ntt.logging.v1.Log
	// only required in the first request message
	Parent *log.ParentName `protobuf:"bytes,1,opt,customtype=ParentName,name=parent,proto3" json:"parent,omitempty" firestore:"parent"`
	// only required in the first request in order to route the request to the
	// correct region
	RegionId string `protobuf:"bytes,2,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty" firestore:"regionId"`
	// List of logs to create/append. If they have specified name
	// field, it must match provided parent field
	Logs []*log.Log `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty" firestore:"logs"`
	// contains filtered or unexported fields
}

A request message of the StreamingCreateLogs method. This method only supports creating logs for the same project and region for the entire duration of the stream. Any client that intends to create logs in multiple projects or regions should not use this API. If the client uses the same scope, service, version and log descriptor, these fields need not be sent after the first message even if binary key is not used in the log entry. The server will set the values observed in the first message in case these are empty and binary key is also not present in the log

func (*StreamingCreateLogsRequest) Descriptor added in v1.8.3

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

Deprecated, Use StreamingCreateLogsRequest.ProtoReflect.Descriptor instead.

func (*StreamingCreateLogsRequest) GetLogs added in v1.8.3

func (m *StreamingCreateLogsRequest) GetLogs() []*log.Log

func (*StreamingCreateLogsRequest) GetParent added in v1.8.3

func (m *StreamingCreateLogsRequest) GetParent() *log.ParentName

func (*StreamingCreateLogsRequest) GetRegionId added in v1.8.3

func (m *StreamingCreateLogsRequest) GetRegionId() string

func (*StreamingCreateLogsRequest) GotenMessage added in v1.8.3

func (*StreamingCreateLogsRequest) GotenMessage()

func (*StreamingCreateLogsRequest) GotenValidate added in v1.8.3

func (obj *StreamingCreateLogsRequest) GotenValidate() error

func (*StreamingCreateLogsRequest) Marshal added in v1.8.3

func (m *StreamingCreateLogsRequest) Marshal() ([]byte, error)

func (*StreamingCreateLogsRequest) MarshalJSON added in v1.8.3

func (m *StreamingCreateLogsRequest) MarshalJSON() ([]byte, error)

func (*StreamingCreateLogsRequest) ProtoMessage added in v1.8.3

func (*StreamingCreateLogsRequest) ProtoMessage()

func (*StreamingCreateLogsRequest) ProtoReflect added in v1.8.3

func (m *StreamingCreateLogsRequest) ProtoReflect() preflect.Message

func (*StreamingCreateLogsRequest) Reset added in v1.8.3

func (m *StreamingCreateLogsRequest) Reset()

func (*StreamingCreateLogsRequest) SetLogs added in v1.8.3

func (m *StreamingCreateLogsRequest) SetLogs(fv []*log.Log)

func (*StreamingCreateLogsRequest) SetParent added in v1.8.3

func (m *StreamingCreateLogsRequest) SetParent(fv *log.ParentName)

func (*StreamingCreateLogsRequest) SetRegionId added in v1.8.3

func (m *StreamingCreateLogsRequest) SetRegionId(fv string)

func (*StreamingCreateLogsRequest) String added in v1.8.3

func (m *StreamingCreateLogsRequest) String() string

func (*StreamingCreateLogsRequest) Unmarshal added in v1.8.3

func (m *StreamingCreateLogsRequest) Unmarshal(b []byte) error

func (*StreamingCreateLogsRequest) UnmarshalJSON added in v1.8.3

func (m *StreamingCreateLogsRequest) UnmarshalJSON(data []byte) error

type StreamingCreateLogsResponse added in v1.8.3

type StreamingCreateLogsResponse struct {

	// Binary key will be set in the map key corresponding to the array index
	// in the request, but only if the particular request entry did not use binary
	// key. Indices for log entries in request having binary key set will be
	// ignored in the response
	BinKeys map[uint32]string `` /* 191-byte string literal not displayed */
	// Logs that failed to be created
	FailedLogs []*CreateLogsResponse_CreateError `protobuf:"bytes,2,rep,name=failed_logs,json=failedLogs,proto3" json:"failed_logs,omitempty" firestore:"failedLogs"`
	// contains filtered or unexported fields
}

A response message of the StreamingCreateLogs method.

func (*StreamingCreateLogsResponse) Descriptor added in v1.8.3

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

Deprecated, Use StreamingCreateLogsResponse.ProtoReflect.Descriptor instead.

func (*StreamingCreateLogsResponse) GetBinKeys added in v1.8.3

func (m *StreamingCreateLogsResponse) GetBinKeys() map[uint32]string

func (*StreamingCreateLogsResponse) GetFailedLogs added in v1.8.3

func (*StreamingCreateLogsResponse) GotenMessage added in v1.8.3

func (*StreamingCreateLogsResponse) GotenMessage()

func (*StreamingCreateLogsResponse) GotenValidate added in v1.8.3

func (obj *StreamingCreateLogsResponse) GotenValidate() error

func (*StreamingCreateLogsResponse) Marshal added in v1.8.3

func (m *StreamingCreateLogsResponse) Marshal() ([]byte, error)

func (*StreamingCreateLogsResponse) MarshalJSON added in v1.8.3

func (m *StreamingCreateLogsResponse) MarshalJSON() ([]byte, error)

func (*StreamingCreateLogsResponse) ProtoMessage added in v1.8.3

func (*StreamingCreateLogsResponse) ProtoMessage()

func (*StreamingCreateLogsResponse) ProtoReflect added in v1.8.3

func (m *StreamingCreateLogsResponse) ProtoReflect() preflect.Message

func (*StreamingCreateLogsResponse) Reset added in v1.8.3

func (m *StreamingCreateLogsResponse) Reset()

func (*StreamingCreateLogsResponse) SetBinKeys added in v1.8.3

func (m *StreamingCreateLogsResponse) SetBinKeys(fv map[uint32]string)

func (*StreamingCreateLogsResponse) SetFailedLogs added in v1.8.3

func (*StreamingCreateLogsResponse) String added in v1.8.3

func (m *StreamingCreateLogsResponse) String() string

func (*StreamingCreateLogsResponse) Unmarshal added in v1.8.3

func (m *StreamingCreateLogsResponse) Unmarshal(b []byte) error

func (*StreamingCreateLogsResponse) UnmarshalJSON added in v1.8.3

func (m *StreamingCreateLogsResponse) UnmarshalJSON(data []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL