log_sink_server

type LogLine struct {
	UserId        string `protobuf:"bytes,1,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	TargetAddress string `protobuf:"bytes,2,opt,name=target_address,json=targetAddress,proto3" json:"target_address,omitempty"`
	TargetHash    string `protobuf:"bytes,3,opt,name=target_hash,json=targetHash,proto3" json:"target_hash,omitempty"`
	Data          []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	CreatedAt     string `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ReceivedAt    string `protobuf:"bytes,6,opt,name=received_at,json=receivedAt,proto3" json:"received_at,omitempty"`
	OrgId         string `protobuf:"bytes,7,opt,name=org_id,json=orgId,proto3" json:"org_id,omitempty"`
	ProjectId     string `protobuf:"bytes,8,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

type LogSinkClient interface {
	Record(ctx context.Context, opts ...grpc.CallOption) (LogSink_RecordClient, error)
}

type LogSinkServer interface {
	Record(LogSink_RecordServer) error
}

type LogSink_RecordClient interface {
	Send(*LogLine) error
	Recv() (*RecordLogLineAck, error)
	grpc.ClientStream
}

type LogSink_RecordServer interface {
	Send(*RecordLogLineAck) error
	Recv() (*LogLine, error)
	grpc.ServerStream
}

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

type UnimplementedLogSinkServer struct {
}